阿卡流，上游不产生价值

我有一个Akka流，我想用来启动一个会话对第三方API，然后我希望它通过在设定的时间间隔发出keepAlive请求保持该会话活着。

现在我设法从流中收集第一个会话签名元素，将其收集到SinkQueue中，但似乎无法获得上游来继续生成元素，这是我的代码：

val signatures = Source.single({ _: String -> sessionManager.logon(logonReq, contractVersion).signature }).keepAlive(interval, {{ signature: String -> sessionManager.keepAlive(KeepAliveRequest(), contractVersion, signature) signature }}) fun start() = signatures. conflateWithSeed({ it("") } ,{ x, f -> f(x) }). runWith(Sink.queue<String>().withAttributes(Attributes.inputBuffer(0, 1)), mat)