C F O P R S T
All Classes All Packages

C

cancel() - Method in interface org.reactivestreams.Subscription

Request the Publisher to stop sending data and clean up resources.

F

FlowAdapters - Class in org.reactivestreams

Bridge between Reactive Streams API and the Java 9 Flow API.

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 to 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 a Publisher 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 its Subscriber(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 Subscriber.onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher.subscribe(Subscriber).

Subscription - Interface in org.reactivestreams

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

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.

C F O P R S T
All Classes All Packages