diff options
author | Jakob Odersky <jakob@inpher.io> | 2019-10-09 17:10:43 -0400 |
---|---|---|
committer | Jakob Odersky <jakob@inpher.io> | 2019-10-09 20:33:16 -0400 |
commit | 0ceee5ed4bae240b8c8e94d2fd7424d9d0b67ec7 (patch) | |
tree | 2df0258f81050e6fed51d38e217c4f6256518e12 /server/src/main/scala/LiveMessages.scala | |
parent | faed28c54900fc0b359700873367095f51425794 (diff) | |
download | scala-triad-0ceee5ed4bae240b8c8e94d2fd7424d9d0b67ec7.tar.gz scala-triad-0ceee5ed4bae240b8c8e94d2fd7424d9d0b67ec7.tar.bz2 scala-triad-0ceee5ed4bae240b8c8e94d2fd7424d9d0b67ec7.zip |
Migrate build to mill
Diffstat (limited to 'server/src/main/scala/LiveMessages.scala')
-rw-r--r-- | server/src/main/scala/LiveMessages.scala | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/server/src/main/scala/LiveMessages.scala b/server/src/main/scala/LiveMessages.scala deleted file mode 100644 index 9729353..0000000 --- a/server/src/main/scala/LiveMessages.scala +++ /dev/null @@ -1,23 +0,0 @@ -package triad - -import akka.NotUsed -import akka.stream.scaladsl.{ - BroadcastHub, - Keep, - Source, - SourceQueueWithComplete -} -import akka.stream.{Materializer, OverflowStrategy} - -class LiveMessages(implicit materializer: Materializer) { - - private val (in: SourceQueueWithComplete[Message], - out: Source[Message, NotUsed]) = Source - .queue[Message](10, OverflowStrategy.dropTail) - .toMat(BroadcastHub.sink[Message])(Keep.both) - .run() - - def push(message: Message) = in.offer(message) - def feed = out - -} |