Top Interfaces Classes
[default module]

Package org.reactivestreams


Interface Summary

Modifier and TypeInterface and Description
public interface
Processor<
the type of element signaled to the Subscriber
T
,
the type of element signaled by the Publisher
R
>

A Processor represents a processing stage—which is both a Subscriber and a Publisher and obeys the contracts of both.

public interface
Publisher<
the type of element signaled
T
>

A Publisher is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from its Subscriber(s).

public interface
Subscriber<
the type of element signaled
T
>

Will receive call to onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher#subscribe(Subscriber).

public interface
Subscription

A Subscription represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher.

Class Summary

Modifier and TypeClass and Description
public class
FlowAdapters

Bridge between Reactive Streams API and the Java 9 java.util.concurrent.Flow API.