reactor.core.publisher

Class ConnectableFlux<T>

java.lang.Object

reactor.core.publisher.Flux<T>

reactor.core.publisher.ConnectableFlux<T>

Type Parameters:

T - the input and output value type

All Implemented Interfaces:

Publisher<T>

public abstract class ConnectableFlux<T>
extends Flux<T>

The abstract base class for connectable publishers that let subscribers pile up before they connect to their data source.

See Also:

Flux.publish(), Reactive-Streams-Commons

Constructor Summary

Constructors

Constructor and Description
ConnectableFlux()

Method Summary

Modifier and Type	Method and Description
Flux<T>	autoConnect() Connects this ConnectableFlux to the upstream source when the first Subscriber subscribes.
Flux<T>	autoConnect(int minSubscribers) Connects this ConnectableFlux to the upstream source when the specified amount of Subscriber subscribes.
Flux<T>	autoConnect(int minSubscribers, Consumer<? super Disposable> cancelSupport) Connects this ConnectableFlux to the upstream source when the specified amount of Subscriber subscribes and calls the supplied consumer with a runnable that allows disconnecting.
Disposable	connect() Connect this ConnectableFlux to its source and return a Runnable that can be used for disconnecting.
abstract void	connect(Consumer<? super Disposable> cancelSupport) Connects this ConnectableFlux to its source and sends a Disposable to a callback that can be used for disconnecting.
Flux<T>	refCount() Connects to the upstream source when the first Subscriber subscribes and disconnects when all Subscribers cancelled or the upstream source completed.
Flux<T>	refCount(int minSubscribers) Connects to the upstream source when the given number of Subscriber subscribes and disconnects when all Subscribers cancelled or the upstream source completed.
Flux<T>	refCount(int minSubscribers, Duration gracePeriod) Connects to the upstream source when the given number of Subscriber subscribes.
Flux<T>	refCount(int minSubscribers, Duration gracePeriod, Scheduler scheduler) Connects to the upstream source when the given number of Subscriber subscribes.

Methods inherited from class reactor.core.publisher.Flux

all, any, as, blockFirst, blockFirst, blockLast, blockLast, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferUntil, bufferUntil, bufferWhen, bufferWhen, bufferWhile, cache, cache, cache, cache, cache, cache, cancelOn, cast, checkpoint, checkpoint, checkpoint, collect, collect, collectList, collectMap, collectMap, collectMap, collectMultimap, collectMultimap, collectMultimap, collectSortedList, collectSortedList, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, compose, concat, concat, concat, concat, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapIterable, concatMapIterable, concatWith, concatWithValues, count, create, create, defaultIfEmpty, defer, delayElements, delayElements, delaySequence, delaySequence, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, distinct, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnComplete, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elapsed, elapsed, elementAt, elementAt, empty, error, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, filterWhen, first, first, flatMap, flatMap, flatMap, flatMap, flatMapDelayError, flatMapIterable, flatMapIterable, flatMapSequential, flatMapSequential, flatMapSequential, flatMapSequentialDelayError, from, fromArray, fromIterable, fromStream, fromStream, generate, generate, generate, getPrefetch, groupBy, groupBy, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, index, index, interval, interval, interval, interval, join, just, just, last, last, limitRate, limitRate, limitRequest, log, log, log, log, log, log, map, materialize, merge, merge, merge, merge, merge, merge, mergeDelayError, mergeOrdered, mergeOrdered, mergeOrdered, mergeOrderedWith, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequentialDelayError, mergeSequentialDelayError, mergeSequentialDelayError, mergeWith, metrics, name, never, next, ofType, onAssembly, onAssembly, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureError, onBackpressureLatest, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onLastAssembly, onTerminateDetach, or, parallel, parallel, parallel, publish, publish, publish, publish, publishNext, publishOn, publishOn, publishOn, push, push, range, reduce, reduce, reduceWith, repeat, repeat, repeat, repeat, repeatWhen, replay, replay, replay, replay, replay, replay, retry, retry, retry, retry, retryBackoff, retryBackoff, retryBackoff, retryBackoff, retryBackoff, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleTimeout, sampleTimeout, scan, scan, scanWith, share, single, single, singleOrEmpty, skip, skip, skip, skipLast, skipUntil, skipUntilOther, skipWhile, sort, sort, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnFirst, switchOnNext, switchOnNext, tag, take, take, take, takeLast, takeUntil, takeUntilOther, takeWhile, then, then, thenEmpty, thenMany, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, using, using, usingWhen, usingWhen, usingWhen, window, window, window, window, window, window, window, windowTimeout, windowTimeout, windowUntil, windowUntil, windowUntil, windowWhen, windowWhile, windowWhile, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith, zipWith, zipWith, zipWithIterable, zipWithIterable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ConnectableFlux

public ConnectableFlux()

Method Detail

autoConnect

public final Flux<T> autoConnect()

Connects this ConnectableFlux to the upstream source when the first Subscriber subscribes.

Returns:

a Flux that connects to the upstream source when the first Subscriber subscribes

autoConnect

public final Flux<T> autoConnect(int minSubscribers)

Connects this ConnectableFlux to the upstream source when the specified amount of Subscriber subscribes.

Subscribing and immediately unsubscribing still contributes to the counter that triggers the connection.

Parameters:

minSubscribers - the minimum number of subscribers

Returns:

a Flux that connects to the upstream source when the given amount of Subscribers subscribed

autoConnect

public final Flux<T> autoConnect(int minSubscribers,
                                 Consumer<? super Disposable> cancelSupport)

Connects this ConnectableFlux to the upstream source when the specified amount of Subscriber subscribes and calls the supplied consumer with a runnable that allows disconnecting.

Parameters:

minSubscribers - the minimum number of subscribers

cancelSupport - the consumer that will receive the Disposable that allows disconnecting

Returns:

a Flux that connects to the upstream source when the given amount of subscribers subscribed

connect

public final Disposable connect()

Connect this ConnectableFlux to its source and return a Runnable that can be used for disconnecting.

Returns:

the Disposable that allows disconnecting the connection after.

connect

public abstract void connect(Consumer<? super Disposable> cancelSupport)

Connects this ConnectableFlux to its source and sends a Disposable to a callback that can be used for disconnecting.

The call should be idempotent in respect of connecting the first and subsequent times. In addition the disconnection should be also tied to a particular connection (so two different connection can't disconnect the other).

Parameters:

cancelSupport - the callback is called with a Disposable instance that can be called to disconnect the source, even synchronously.

refCount

public final Flux<T> refCount()

Connects to the upstream source when the first Subscriber subscribes and disconnects when all Subscribers cancelled or the upstream source completed.

Returns:

a reference counting Flux

refCount

public final Flux<T> refCount(int minSubscribers)

Connects to the upstream source when the given number of Subscriber subscribes and disconnects when all Subscribers cancelled or the upstream source completed.

Parameters:

minSubscribers - the number of subscribers expected to subscribe before connection

Returns:

a reference counting Flux

refCount

public final Flux<T> refCount(int minSubscribers,
                              Duration gracePeriod)

Connects to the upstream source when the given number of Subscriber subscribes. Disconnection can happen in two scenarios: when the upstream source completes (or errors) then there is an immediate disconnection. However, when all subscribers have cancelled, a deferred disconnection is scheduled. If any new subscriber comes in during the gracePeriod that follows, the disconnection is cancelled.

Parameters:

minSubscribers - the number of subscribers expected to subscribe before connection

gracePeriod - the Duration for which to wait for new subscribers before actually disconnecting when all subscribers have cancelled.

Returns:

a reference counting Flux with a grace period for disconnection

refCount

public final Flux<T> refCount(int minSubscribers,
                              Duration gracePeriod,
                              Scheduler scheduler)

Connects to the upstream source when the given number of Subscriber subscribes. Disconnection can happen in two scenarios: when the upstream source completes (or errors) then there is an immediate disconnection. However, when all subscribers have cancelled, a deferred disconnection is scheduled. If any new subscriber comes in during the gracePeriod that follows, the disconnection is cancelled.

Parameters:

minSubscribers - the number of subscribers expected to subscribe before connection

gracePeriod - the Duration for which to wait for new subscribers before actually disconnecting when all subscribers have cancelled.

scheduler - the Scheduler on which to run timeouts

Returns:

a reference counting Flux with a grace period for disconnection