Migrate build to mill

1 files changed, 23 insertions, 0 deletions

diff --git a/server/src/LiveMessages.scala b/server/src/LiveMessages.scala
new file mode 100644
index 0000000..9729353
--- /dev/null
+++ b/server/src/LiveMessages.scala
@@ -0,0 +1,23 @@
+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
+
+}