reactor.core

接口 CorePublisher<T>

类型参数:

T - the CoreSubscriber data type

所有超级接口:

org.reactivestreams.Publisher<T>

所有已知实现类:

ConnectableFlux, DirectProcessor, EmitterProcessor, Flux, FluxOperator, FluxProcessor, GroupedFlux, MockUtils.TestScannableConnectableFlux, Mono, MonoOperator, MonoProcessor, ParallelFlux, ReplayProcessor, UnicastProcessor

public interface CorePublisher<T>
extends org.reactivestreams.Publisher<T>

A CoreSubscriber aware publisher.

从以下版本开始:

3.3.0

方法概要

限定符和类型	方法和说明
void	subscribe(CoreSubscriber<? super T> subscriber) An internal Publisher.subscribe(Subscriber) that will bypass Hooks.onLastOperator(Function) pointcut.

从接口继承的方法 org.reactivestreams.Publisher

subscribe

方法详细资料

subscribe

void subscribe(CoreSubscriber<? super T> subscriber)

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.

参数:

subscriber - the Subscriber interested into the published sequence

另请参阅:

Publisher.subscribe(Subscriber)