Convert Disposable to Kotlin Flow?

[SeanOThomas]

We want to get real time unread count updates. According to the docs, we should use the lower-level client subscribeFor method which returns a GetStream Disposable. It's not ideal for us to expose Disposable beyond the data layer. Is there a convenient or noted way of converting the Disposable to Kotlin Flow data? Thanks!

[zsmb13]

We don't have API for this yet, but we'll look into providing it.

In the meantime, you should be able to use the callbackFlow function from kotlinx.coroutines to convert any callback based API into a Flow. For our event API, that would look something like this (haven't tested it, just a basic draft):

val flow = callbackFlow<ChatEvent> {
    val disposable = client.subscribeFor(ChatEventListener { event ->
        this.trySendBlocking(event)
    })
    awaitClose {
        disposable.dispose()
    }
}

// In a coroutine
flow.collect { event: ChatEvent -> 
    // ...
}