Akka stream, upstream no produce valores

Tengo una transmisión de Akka que quiero usar para iniciar una session contra una API de terceros y luego quiero que la session se mantenga activa al emitir las requestes de KeepAlive en un intervalo establecido.

Ahora he logrado recostackr el elemento de firma de la primera session de la secuencia al recostackrlo en un SinkQueue, pero parece que no puedo avanzar para seguir produciendo elementos, este es mi código:

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)