Initial commit

1 files changed, 18 insertions, 0 deletions

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