reactor.core.publisher

接口 Sinks.ManyWithUpstream<T>

类型参数:

T - the type of data emitted by the sink

所有超级接口:

Scannable, Sinks.Many<T>

所有已知实现类:

EmitterProcessor

封闭类:

Sinks

public static interface Sinks.ManyWithUpstream<T>
extends Sinks.Many<T>

A Sinks.Many which additionally allows being subscribed to an upstream Publisher, which is an advanced pattern requiring external synchronization. See subscribeTo(Publisher)} for more details.

嵌套类概要

从接口继承的嵌套类/接口 reactor.core.Scannable

Scannable.Attr<T>

字段概要

从接口继承的字段 reactor.core.Scannable

OPERATOR_NAME_UNRELATED_WORDS_PATTERN

方法概要

限定符和类型	方法和说明
Disposable	subscribeTo(org.reactivestreams.Publisher<? extends T> upstream) Explicitly subscribe this Sinks.Many to an upstream Publisher without exposing it as a Subscriber at all.

从接口继承的方法 reactor.core.publisher.Sinks.Many

asFlux, currentSubscriberCount, emitComplete, emitError, emitNext, tryEmitComplete, tryEmitError, tryEmitNext

从接口继承的方法 reactor.core.Scannable

actuals, from, inners, isScanAvailable, name, parents, scan, scanOrDefault, scanUnsafe, stepName, steps, tags, tagsDeduplicated

方法详细资料

subscribeTo

Disposable subscribeTo(org.reactivestreams.Publisher<? extends T> upstream)

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 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 Sinks.ManyWithUpstream multiple times throws an IllegalStateException indicating that the subscription must be unique.