Top Description Methods
reactor.core

public Interface CorePublisher<T>

extends Publisher<T>
Known Direct Subinterfaces
reactor.core.publisher.OptimizableOperator
Known Direct Implementers
reactor.core.publisher.Operators.CorePublisherAdapter, reactor.core.publisher.ParallelFlux, reactor.core.publisher.Mono, reactor.core.publisher.Flux
Type Parameters
<T>
the CoreSubscriber data type
Imports
java.util.function.Function, org.reactivestreams.Publisher, .Subscriber, reactor.core.publisher.Hooks, reactor.util.context.Context
A CoreSubscriber aware publisher.
Since
3.3.0

Method Summary

Modifier and TypeMethod and Description
public void
subscribe(CoreSubscriber<? super T>
the Subscriber interested into the published sequence
subscriber)

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

Inherited from org.reactivestreams.Publisher:
subscribe

Method Detail

subscribeback to summary
public 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:CoreSubscriber<? super T>

the Subscriber interested into the published sequence

See Also
Publisher#subscribe(Subscriber)