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).