diff options
| author | Jakob Odersky <jakob@inpher.io> | 2019-10-09 20:32:48 -0400 |
|---|---|---|
| committer | Jakob Odersky <jakob@inpher.io> | 2019-10-09 20:33:16 -0400 |
| commit | f67c8d59a26132a8d7c80b3e15bddc35ba0091d9 (patch) | |
| tree | eb733861e64397d7b36b2ee00aa97e8a92a9044f /server | |
| parent | 0ceee5ed4bae240b8c8e94d2fd7424d9d0b67ec7 (diff) | |
| download | scala-triad-f67c8d59a26132a8d7c80b3e15bddc35ba0091d9.tar.gz scala-triad-f67c8d59a26132a8d7c80b3e15bddc35ba0091d9.tar.bz2 scala-triad-f67c8d59a26132a8d7c80b3e15bddc35ba0091d9.zip | |
format
Diffstat (limited to 'server')
| -rw-r--r-- | server/src/LiveMessages.scala | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/server/src/LiveMessages.scala b/server/src/LiveMessages.scala index 9729353..b2d27c1 100644 --- a/server/src/LiveMessages.scala +++ b/server/src/LiveMessages.scala @@ -11,8 +11,10 @@ import akka.stream.{Materializer, OverflowStrategy} class LiveMessages(implicit materializer: Materializer) { - private val (in: SourceQueueWithComplete[Message], - out: Source[Message, NotUsed]) = Source + private val ( + in: SourceQueueWithComplete[Message], + out: Source[Message, NotUsed] + ) = Source .queue[Message](10, OverflowStrategy.dropTail) .toMat(BroadcastHub.sink[Message])(Keep.both) .run() |