@ExperimentalCoroutinesApi // Since 1.2.1, tentatively till 1.3.0
public suspend inline fun <T> ObservableSource<T>.collect(action: (T) -> Unit) =
openSubscription().consumeEach(action)
will there be any changes in above method in coming releases ?
g
gildor
09/17/2019, 6:31 AM
I would instead create an issue on kotlinx.coroutines tracker instead