Hey there! I am new to Kotlin and I am learning how to work with Kotlin semantics... I am a bit stuck when trying to figure out how to go about bridging a Ktor request handler coroutine and a RX pipeline. This is the example, obviously the issue is that writer is already done by the time RX does its thing. How do I proceed?