Switch to keepAlive.

Much better.
pull/6652/head
Lakin Wecker 2020-05-19 08:07:13 -06:00
parent 1ffa73157d
commit 0bf40bb19f
1 changed files with 1 additions and 1 deletions

View File

@ -102,7 +102,7 @@ final class GameApiV2(
.mapConcat(_ filter config.postFilter)
.take(config.max | Int.MaxValue)
.via(preparationFlow(config))
.merge(Source.tick(keepAliveInterval, keepAliveInterval, emptyMsgFor(config)))
.keepAlive(keepAliveInterval, () => emptyMsgFor(config))
def exportByIds(config: ByIdsConfig): Source[String, _] =
gameRepo