Implements reactor.core.publisher.Sinks.Many.asFlux.

Doc from reactor.core.publisher.Sinks.Many.asFlux.

Return a Flux view of this sink. Every call returns the same instance.

Returns:Flux<T>

the Flux view associated to this Sinks.Many

Annotations

@Override

Create a new EmitterProcessor using Queues#SMALL_BUFFER_SIZE backlog size and auto-cancel.

Parameters

<E>

Type of processed signals

Returns:EmitterProcessor<E>

a fresh processor

Annotations

@Deprecated

Create a new EmitterProcessor using Queues#SMALL_BUFFER_SIZE backlog size and the provided auto-cancel.

Parameters

<E>

Type of processed signals

autoCancel:boolean

automatically cancel

Returns:EmitterProcessor<E>

a fresh processor

Annotations

@Deprecated

Create a new EmitterProcessor using the provided backlog size, with auto-cancel.

Parameters

<E>

Type of processed signals

bufferSize:int

the internal buffer size to hold signals

Returns:EmitterProcessor<E>

a fresh processor

Annotations

@Deprecated

Create a new EmitterProcessor using the provided backlog size and auto-cancellation.

Parameters

<E>

Type of processed signals

bufferSize:int

the internal buffer size to hold signals

autoCancel:boolean

automatically cancel

Returns:EmitterProcessor<E>

a fresh processor

Annotations

@Deprecated

Overrides reactor.core.publisher.FluxProcessor.currentContext.

Overrides default reactor.core.CoreSubscriber.currentContext.

Implements reactor.core.publisher.ContextHolder.currentContext.

Doc from reactor.core.publisher.ContextHolder.currentContext.

Request a Context from dependent components which can include downstream operators during subscribing or a terminal org.reactivestreams.Subscriber.

Returns:Context

a resolved context

Annotations

@Override

Implements reactor.core.publisher.Sinks.Many.currentSubscriberCount.

Doc from reactor.core.publisher.Sinks.Many.currentSubscriberCount.

Get how many Subscribers are currently subscribed to the sink.

This is a best effort peek at the sink state, and a subsequent attempt at emitting to the sink might still return EmitResult#FAIL_ZERO_SUBSCRIBER where relevant. (generally in tryEmitNext(Object)). Request (and lack thereof) isn't taken into account, all registered subscribers are counted.

Returns:int

the number of subscribers at the time of invocation

Annotations

@Override

Overrides reactor.core.publisher.FluxProcessor.downstreamCount.

Doc from reactor.core.publisher.FluxProcessor.downstreamCount.

Return the number of active Subscriber or -1 if untracked.

Returns:long

the number of active Subscriber or -1 if untracked

Annotations

@Override

Overrides reactor.core.publisher.FluxProcessor.getBufferSize.

Doc from reactor.core.publisher.FluxProcessor.getBufferSize.

Return the processor buffer capacity if any or Integer#MAX_VALUE

Returns:int

processor buffer capacity if any or Integer#MAX_VALUE

Annotations

@Override

Overrides reactor.core.publisher.FluxProcessor.getError.

Doc from reactor.core.publisher.FluxProcessor.getError.

Current error if any, default to null

Returns:Throwable

Current error if any, default to null

Annotations

@Override

@Nullable

Return the number of parked elements in the emitter backlog.

Returns:int

the number of parked elements in the emitter backlog.

Overrides reactor.core.publisher.Flux.getPrefetch.

Doc from reactor.core.publisher.Flux.getPrefetch.

The prefetch configuration of the Flux

Returns:int

the prefetch configuration of the Flux, -1 if unspecified

Annotations

@Override

Overrides reactor.core.publisher.FluxProcessor.inners.

Overrides default reactor.core.Scannable.inners.

Doc from reactor.core.Scannable.inners.

Return a Stream of referenced inners (flatmap, multicast etc)

Returns:Stream<? extends Scannable>

a Stream of referenced inners (flatmap, multicast etc)

Annotations

@Override

Returns:boolean

true if all subscribers have actually been cancelled and the processor auto shut down

Overrides default reactor.core.Disposable.isDisposed.

Doc from reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

Returns:boolean

true when there's a guarantee the resource or task is disposed.

Annotations

@Override

Overrides reactor.core.publisher.FluxProcessor.isTerminated.

Doc from reactor.core.publisher.FluxProcessor.isTerminated.

Has this upstream finished or "completed" / "failed" ?

Returns:boolean

has this upstream finished or "completed" / "failed" ?

Annotations

@Override

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations

@Override

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters

throwable:Throwable

the throwable signaled

Annotations

@Override

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

t:T

the element signaled

Annotations

@Override

Implements org.reactivestreams.Subscriber.onSubscribe, reactor.core.CoreSubscriber.onSubscribe.

Doc from reactor.core.CoreSubscriber.onSubscribe.

Implementors should initialize any state used by onNext(Object) before calling Subscription#request(long). Should further onNext related state modification occur, thread-safety will be required.

Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled reactor.util.Logger. Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters

s:Subscription

Doc from org.reactivestreams.Subscriber.onSubscribe.

the Subscription that allows requesting data via Subscription#request(long)

Annotations

@Override

Overrides reactor.core.publisher.FluxProcessor.scanUnsafe.

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>

a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override

@Nullable

Implements abstract reactor.core.publisher.Flux.subscribe.

Implements reactor.core.CorePublisher.subscribe.

Doc from reactor.core.publisher.Flux.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.

In addition to behave as expected by Publisher#subscribe(Subscriber) in a controlled manner, it supports direct subscribe-time Context passing.

Parameters

actual:CoreSubscriber<? super T>

the Subscriber interested into the published sequence

Annotations

@Override

Implements reactor.core.publisher.Sinks.ManyWithUpstream.subscribeTo.

Doc from reactor.core.publisher.Sinks.ManyWithUpstream.subscribeTo.

Explicitly subscribe this Sinks.Many to an upstream Publisher without exposing it as a Subscriber at all.

Note that when this is done, one MUST stop using emit/tryEmit APIs, reserving signal creation to be the sole responsibility of the upstream Publisher.

The returned Disposable provides a way of both unsubscribing from the upstream and terminating the sink: currently registered subscribers downstream receive an onError signal with a java.util.concurrent.CancellationException and further attempts at subscribing to the sink will trigger a similar signal immediately (in which case the returned Disposable might be no-op).

Any attempt at subscribing the same ManyWithUpstream multiple times throws an IllegalStateException indicating that the subscription must be unique.

Annotations

@Override

Implements reactor.core.publisher.Sinks.Many.tryEmitComplete.

Doc from reactor.core.publisher.Sinks.Many.tryEmitComplete.

Try to terminate the sequence successfully, generating an onComplete signal. The result of the attempt is represented as an EmitResult, which possibly indicates error cases.

See the list of failure EmitResult in emitComplete(EmitFailureHandler) javadoc for an example of how each of these can be dealt with, to decide if the emit API would be a good enough fit instead.

Returns:Sinks.EmitResult

an EmitResult, which should be checked to distinguish different possible failures

Annotations

@Override

Implements reactor.core.publisher.Sinks.Many.tryEmitError.

Doc from reactor.core.publisher.Sinks.Many.tryEmitError.

Try to fail the sequence, generating an onError signal. The result of the attempt is represented as an EmitResult, which possibly indicates error cases.

See the list of failure EmitResult in emitError(Throwable, EmitFailureHandler) javadoc for an example of how each of these can be dealt with, to decide if the emit API would be a good enough fit instead.

Parameters

t:Throwable

the exception to signal, not null

Returns:Sinks.EmitResult

an EmitResult, which should be checked to distinguish different possible failures

Annotations

@Override

Implements reactor.core.publisher.Sinks.Many.tryEmitNext.

Doc from reactor.core.publisher.Sinks.Many.tryEmitNext.

Try emitting a non-null element, generating an onNext signal. The result of the attempt is represented as an EmitResult, which possibly indicates error cases.

See the list of failure EmitResult in emitNext(Object, EmitFailureHandler) javadoc for an example of how each of these can be dealt with, to decide if the emit API would be a good enough fit instead.

Might throw an unchecked exception as a last resort (eg. in case of a fatal error downstream which cannot be propagated to any asynchronous handler, a bubbling exception, ...).

Parameters

t:T

the value to emit, not null

Returns:Sinks.EmitResult

an EmitResult, which should be checked to distinguish different possible failures

Annotations

@Override