diff options
Diffstat (limited to 'server/src/LiveMessages.scala')
| -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() |