reactor.core

Interface CorePublisher<T>

Type Parameters:

T - the CoreSubscriber data type

All Superinterfaces:

Publisher<T>

All Known Implementing Classes:

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

public interface CorePublisher<T>
extends Publisher<T>

A CoreSubscriber aware publisher.

Since:

3.3.0

Method Summary

Modifier and Type	Method and Description
void	subscribe(CoreSubscriber<? super T> subscriber) An internal Publisher.subscribe(Subscriber) that will bypass Hooks.onLastOperator(Function) pointcut.

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Method Detail

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.

Parameters:

subscriber - the Subscriber interested into the published sequence

See Also:

Publisher.subscribe(Subscriber)