fluencelabs/cosmos-hackathon-backend
1
0
Fork 0
mirror of https://github.com/fluencelabs/cosmos-hackathon-backend synced 2025-03-15 12:00:50 +00:00
Code Issues Projects Releases Wiki Activity

stream docker log

Browse Source
This commit is contained in:
folex 2019-06-15 10:58:47 +02:00
parent efc419f3d5
commit 7267f44d24
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/scala/hackhack/WebsocketServer.scala
View File

@ -83,7 +83,8 @@ case class WebsocketServer[F[_]: ConcurrentEffect: Timer: ContextShift](
case (GET | POST) -> Root / "create" / key =>
val stream =
fs2.Stream
.eval(Sync[F].delay(Files.createTempFile("websocket", key)))
// .eval(Sync[F].delay(Files.createTempFile("websocket", key)))
.eval(Sync[F].delay(Paths.get("/tmp/docker.log")))
.evalTap(path => Sync[F].delay(println(s"created $path")))
.flatMap(FileStream.stream[F])
.map(Event(_))