reactor.core.publisher

接口 FluxSink<T>

类型参数:

T - the value type

public interface FluxSink<T>

Wrapper API around a downstream Subscriber for emitting any number of next signals followed by zero or one onError/onComplete.

嵌套类概要

嵌套类

限定符和类型	接口和说明
static class	FluxSink.OverflowStrategy Enumeration for backpressure handling.

方法概要

限定符和类型	方法和说明
void	complete() Terminate the sequence successfully, generating an onComplete signal.
default ContextView	contextView() Return the current subscriber's context as a ContextView for inspection.
Context	currentContext() 已过时。 To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.
void	error(java.lang.Throwable e) Fail the sequence, generating an onError signal.
boolean	isCancelled() Returns true if the downstream cancelled the sequence.
FluxSink<T>	next(T t) Emit a non-null element, generating an onNext signal.
FluxSink<T>	onCancel(Disposable d) Attach a Disposable as a callback for when this FluxSink is cancelled.
FluxSink<T>	onDispose(Disposable d) Attach a Disposable as a callback for when this FluxSink is effectively disposed, that is it cannot be used anymore.
FluxSink<T>	onRequest(java.util.function.LongConsumer consumer) Attaches a LongConsumer to this FluxSink that will be notified of any request to this sink.
long	requestedFromDownstream() The current outstanding request amount.

方法详细资料

next

FluxSink<T> next(T t)

Emit a non-null element, generating an onNext signal.

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

参数:

t - the value to emit, not null

返回:

this sink for chaining further signals

complete

void complete()

Terminate the sequence successfully, generating an onComplete signal.

另请参阅:

Subscriber.onComplete()

error

void error(java.lang.Throwable e)

Fail the sequence, generating an onError signal.

参数:

e - the exception to signal, not null

另请参阅:

Subscriber.onError(Throwable)

currentContext

@Deprecated
Context currentContext()

已过时。 To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.

Return the current subscriber Context.

Context can be enriched via Flux.contextWrite(Function) operator or directly by a child subscriber overriding CoreSubscriber.currentContext()

contextView

default ContextView contextView()

Return the current subscriber's context as a ContextView for inspection.

Context can be enriched downstream via Flux.contextWrite(Function) operator or directly by a child subscriber overriding CoreSubscriber.currentContext().

返回:

the current subscriber ContextView.

requestedFromDownstream

long requestedFromDownstream()

The current outstanding request amount.

返回:

the current outstanding request amount

isCancelled

boolean isCancelled()

Returns true if the downstream cancelled the sequence.

返回:

true if the downstream cancelled the sequence

onRequest

FluxSink<T> onRequest(java.util.function.LongConsumer consumer)

Attaches a LongConsumer to this FluxSink that will be notified of any request to this sink.

For push/pull sinks created using Flux.create(java.util.function.Consumer) or Flux.create(java.util.function.Consumer, FluxSink.OverflowStrategy), the consumer is invoked for every request to enable a hybrid backpressure-enabled push/pull model. When bridging with asynchronous listener-based APIs, the onRequest callback may be used to request more data from source if required and to manage backpressure by delivering data to sink only when requests are pending.

For push-only sinks created using Flux.push(java.util.function.Consumer) or Flux.push(java.util.function.Consumer, FluxSink.OverflowStrategy), the consumer is invoked with an initial request of Long.MAX_VALUE when this method is invoked.

参数:

consumer - the consumer to invoke on each request

返回:

FluxSink with a consumer that is notified of requests

onCancel

FluxSink<T> onCancel(Disposable d)

Attach a Disposable as a callback for when this FluxSink is cancelled. At most one callback can be registered, and subsequent calls to this method will result in the immediate disposal of the extraneous Disposable.

The callback is only relevant when the downstream Subscription is cancelled.

参数:

d - the Disposable to use as a callback

返回:

the FluxSink with a cancellation callback

另请参阅:

onDispose(Disposable) for a callback that covers cancellation AND terminal signals

onDispose

FluxSink<T> onDispose(Disposable d)

Attach a Disposable as a callback for when this FluxSink is effectively disposed, that is it cannot be used anymore. This includes both having played terminal signals (onComplete, onError) and having been cancelled (see onCancel(Disposable)). At most one callback can be registered, and subsequent calls to this method will result in the immediate disposal of the extraneous Disposable.

Note that the "dispose" term is used from the perspective of the sink. Not to be confused with Flux.subscribe()'s Disposable.dispose() method, which maps to disposing the Subscription (effectively, a Subscription.cancel() signal).

参数:

d - the Disposable to use as a callback

返回:

the FluxSink with a callback invoked on any terminal signal or on cancellation

另请参阅:

onCancel(Disposable) for a cancellation-only callback