From 3de6739b8b6f04956c8908bc9717990807254a6b Mon Sep 17 00:00:00 2001 From: Jakob Odersky Date: Fri, 11 Oct 2019 20:38:55 -0400 Subject: add logging and some comments --- server/src/Routes.scala | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'server/src/Routes.scala') diff --git a/server/src/Routes.scala b/server/src/Routes.scala index 0b08a11..d1bbefd 100644 --- a/server/src/Routes.scala +++ b/server/src/Routes.scala @@ -25,12 +25,11 @@ class Routes(repository: Repository, liveMessages: LiveMessages) { private val lastMessages = repository.Messages.take(100).result - private val messageStream: Source[Message, _] = { - val publisher = repository.database.stream(lastMessages) + // stream persisted messages first, followed by live ones + private val messageStream: Source[Message, _] = Source - .fromPublisher(publisher) + .fromPublisher(repository.database.stream(lastMessages)) .concat(liveMessages.feed) - } val messages = path("messages") { get { -- cgit v1.2.3