reactor.core

Interface Receiver

All Known Implementing Classes:

ConnectableFlux, DirectProcessor, EmitterProcessor, FluxCancelOn, FluxElapsed, FluxSource, MonoCancelOn, MonoElapsed, MonoProcessor, MonoSource, Operators.DeferredSubscription, Operators.MonoSubscriber, Operators.SubscriberAdapter, ReplayProcessor, TopicProcessor, UnicastProcessor, WorkQueueProcessor

public interface Receiver

A component that is linked to a source producer.

Method Summary

Modifier and Type	Method and Description
java.lang.Object	upstream() Return the direct source of data, Supports reference.

Method Detail

upstream

java.lang.Object upstream()

Return the direct source of data, Supports reference.

Returns:

the direct source of data, Supports reference.