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:

org.reactivestreams.Publisher<T>, Receiver

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

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

See Also:

Flux.process(org.reactivestreams.Processor<? super T, ? extends T>), 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, java.util.function.Consumer<? super Cancellation> 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.
Cancellation	connect() Connect this ConnectableFlux to its source and return a Runnable that can be used for disconnecting.
abstract void	connect(java.util.function.Consumer<? super Cancellation> cancelSupport) Connects this ConnectableFlux to its source and sends a Cancellation 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.

Methods inherited from class reactor.core.publisher.Flux

all, any, as, awaitOnSubscribe, blockFirst, blockFirst, blockFirstMillis, blockLast, blockLast, blockLastMillis, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferMillis, bufferMillis, bufferMillis, bufferMillis, bufferMillis, bufferMillis, cache, cache, cast, 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, count, create, create, defaultIfEmpty, defer, delay, delayMillis, delayMillis, delaySubscription, delaySubscription, delaySubscriptionMillis, delaySubscriptionMillis, dematerialize, distinct, distinct, distinctUntilChanged, distinctUntilChanged, doAfterTerminate, doOnCancel, doOnComplete, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elapsed, elementAt, elementAtOrDefault, empty, error, error, every, everyFirst, filter, firstEmitting, firstEmitting, firstEmittingWith, flatMap, flatMap, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, from, fromArray, fromIterable, fromStream, generate, generate, generate, getPrefetch, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, interval, interval, intervalMillis, intervalMillis, intervalMillis, intervalMillis, join, just, just, last, log, log, log, map, mapError, mapError, mapError, materialize, merge, merge, merge, merge, merge, merge, mergeWith, never, next, onAssembly, onAssembly, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureError, onBackpressureLatest, onErrorResumeWith, onErrorResumeWith, onErrorResumeWith, onErrorReturn, onErrorReturn, onErrorReturn, onTerminateDetach, parallel, parallel, parallel, process, process, process, process, publish, publish, publish, publish, publishNext, publishOn, publishOn, range, reduce, reduce, reduceWith, repeat, repeat, repeat, repeat, repeatWhen, replay, replay, retry, retry, retry, retry, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleFirstMillis, sampleMillis, sampleTimeout, sampleTimeout, scan, scan, scanWith, single, singleOrDefault, singleOrEmpty, skip, skip, skipLast, skipMillis, skipMillis, skipUntil, skipUntilOther, skipWhile, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnError, switchOnError, switchOnError, switchOnNext, switchOnNext, take, take, takeLast, takeMillis, takeMillis, takeUntil, takeUntilOther, takeWhile, then, then, then, thenMany, thenMany, timeout, timeout, timeout, timeout, timeout, timeoutMillis, timeoutMillis, timeoutMillis, timeoutMillis, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, using, using, window, window, window, window, window, window, window, window, windowMillis, windowMillis, windowMillis, windowMillis, windowMillis, windowMillis, withLatestFrom, 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

Methods inherited from interface reactor.core.Receiver

upstream

Methods inherited from interface org.reactivestreams.Publisher

subscribe

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 Subscribers also contribute the the subscription count 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 subscribe

autoConnect

public final Flux<T> autoConnect(int minSubscribers,
                                 java.util.function.Consumer<? super Cancellation> 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 Cancellation that allows disconnecting

Returns:

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

connect

public final Cancellation connect()

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

Returns:

the Cancellation that allows disconnecting the connection after.

connect

public abstract void connect(java.util.function.Consumer<? super Cancellation> cancelSupport)

Connects this ConnectableFlux to its source and sends a Cancellation 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 Cancellation 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