reactor.core

Interface MultiProducer

All Known Implementing Classes:

DirectProcessor, EmitterProcessor, MonoProcessor, ReplayProcessor, TopicProcessor, WorkQueueProcessor

public interface MultiProducer

A component that will emit events to N downstreams.

Method Summary

Modifier and Type	Method and Description
default long	downstreamCount() the number of downstream receivers
Iterator<?>	downstreams() the connected data receivers
default boolean	hasDownstreams() Has any Subscriber attached to this multi-producer ?

Method Detail

downstreams

Iterator<?> downstreams()

the connected data receivers

Returns:

the connected data receivers

downstreamCount

default long downstreamCount()

the number of downstream receivers

Returns:

the number of downstream receivers

hasDownstreams

default boolean hasDownstreams()

Has any Subscriber attached to this multi-producer ?

Returns:

Has any Subscriber attached to this multi-producer ?