openSubscription
@JvmOverloads fun <T> Observable<T>.openSubscription(
request: Int = 0
): SubscriptionReceiveChannel<T>Subscribes to this Observable and returns a channel to receive elements emitted by it. The resulting channel shall be closed to unsubscribe from this observable.
Parameters
request - how many items to request from publisher in advance (optional, on-demand request by default).