reactor.core

Interface Receiver

All Known Implementing Classes:

BaseSubscriber, ConnectableFlux, DirectProcessor, EmitterProcessor, FluxSource, 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
Object	upstream() Return the direct source of data, Supports reference.

Method Detail

upstream

Object upstream()

Return the direct source of data, Supports reference.

Returns:

the direct source of data, Supports reference.