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