- Reactive Streams Spec: The purpose of Reactive Streams is to provide a standard for asynchronous stream processing with non-blocking backpressure.
- Publisher:
void subscribe(Subscriber<? super T> s)
- Subscriber:
void onSubscribe(Subscription s); void onNext(T t);
- Publisher:
void onError(Throwable t);