aboutsummaryrefslogtreecommitdiff
path: root/server/src/main/scala/LiveMessages.scala
diff options
context:
space:
mode:
authorJakob Odersky <jakob@inpher.io>2019-10-09 17:10:43 -0400
committerJakob Odersky <jakob@inpher.io>2019-10-09 20:33:16 -0400
commit0ceee5ed4bae240b8c8e94d2fd7424d9d0b67ec7 (patch)
tree2df0258f81050e6fed51d38e217c4f6256518e12 /server/src/main/scala/LiveMessages.scala
parentfaed28c54900fc0b359700873367095f51425794 (diff)
downloadscala-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.scala23
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
-
-}