runLive
fun runLive(userId: String, sessionId: String, liveRequestQueue: LiveRequestQueue, runConfig: RunConfig? = null): Publisher<Event>
Experimental: runs the agent over a live connection, streaming the whole conversation's events (see Runner.runLive). Each subscription starts its own run, which ends when liveRequestQueue is closed or the model ends the session; cancelling the subscription closes the connection and leaves the queue open. Events arrive on Dispatchers.IO, never on the thread that sends to the queue; hand slow work in onNext to your own executor.