Index
All Classes and Interfaces|All Packages
C
- cancel() - Method in interface org.reactivestreams.Subscription
-
Request the
Publisher
to stop sending data and clean up resources.
O
- onComplete() - Method in interface org.reactivestreams.Subscriber
-
Successful terminal state.
- onError(Throwable) - Method in interface org.reactivestreams.Subscriber
-
Failed terminal state.
- onNext(T) - Method in interface org.reactivestreams.Subscriber
-
Data notification sent by the
Publisher
in response to requests toSubscription.request(long)
. - onSubscribe(Subscription) - Method in interface org.reactivestreams.Subscriber
-
Invoked after calling
Publisher.subscribe(Subscriber)
. - org.reactivestreams - package org.reactivestreams
P
- Processor<T,
R> - Interface in org.reactivestreams -
A Processor represents a processing stage—which is both a
Subscriber
and aPublisher
and obeys the contracts of both. - Publisher<T> - Interface in org.reactivestreams
-
A
Publisher
is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber
(s).
R
- request(long) - Method in interface org.reactivestreams.Subscription
-
No events will be sent by a
Publisher
until demand is signaled via this method.
S
- subscribe(Subscriber<? super T>) - Method in interface org.reactivestreams.Publisher
-
Request
Publisher
to start streaming data. - Subscriber<T> - Interface in org.reactivestreams
-
Will receive call to
onSubscribe(Subscription)
once after passing an instance ofSubscriber
toPublisher.subscribe(Subscriber)
. - Subscription - Interface in org.reactivestreams
All Classes and Interfaces|All Packages