C F O P R S T
All Classes All Packages
All Classes All Packages
All Classes All Packages
C
- cancel() - Method in interface org.reactivestreams.Subscription
-
Request the
Publisherto stop sending data and clean up resources.
F
- FlowAdapters - Class in org.reactivestreams
-
Bridge between Reactive Streams API and the Java 9
FlowAPI.
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
Publisherin response to requests torequest(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
Subscriberand aPublisherand obeys the contracts of both. - Publisher<T> - Interface in org.reactivestreams
-
A
Publisheris 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
Publisheruntil demand is signaled via this method.
S
- subscribe(Subscriber<? super T>) - Method in interface org.reactivestreams.Publisher
-
Request
Publisherto start streaming data. - Subscriber<T> - Interface in org.reactivestreams
-
Will receive call to
Subscriber.onSubscribe(Subscription)once after passing an instance ofSubscribertoPublisher.subscribe(Subscriber). - Subscription - Interface in org.reactivestreams
T
- toFlowProcessor(Processor<? super T, ? extends U>) - Static method in class org.reactivestreams.FlowAdapters
-
Converts a Reactive Streams Processor into a Flow Processor.
- toFlowPublisher(Publisher<? extends T>) - Static method in class org.reactivestreams.FlowAdapters
-
Converts a Reactive Streams Publisher into a Flow Publisher.
- toFlowSubscriber(Subscriber<T>) - Static method in class org.reactivestreams.FlowAdapters
-
Converts a Reactive Streams Subscriber into a Flow Subscriber.
- toProcessor(Flow.Processor<? super T, ? extends U>) - Static method in class org.reactivestreams.FlowAdapters
-
Converts a Flow Processor into a Reactive Streams Processor.
- toPublisher(Flow.Publisher<? extends T>) - Static method in class org.reactivestreams.FlowAdapters
-
Converts a Flow Publisher into a Reactive Streams Publisher.
- toSubscriber(Flow.Subscriber<T>) - Static method in class org.reactivestreams.FlowAdapters
-
Converts a Flow Subscriber into a Reactive Streams Subscriber.
All Classes All Packages