A I N O R S W 
All Classes All Packages

A

AsyncIterablePublisher<T> - Class in org.reactivestreams.example.unicast
AsyncIterablePublisher is an implementation of Reactive Streams `Publisher` which executes asynchronously, using a provided `Executor` and produces elements from a given `Iterable` in a "unicast" configuration to its `Subscribers`.
AsyncIterablePublisher(Iterable<T>, int, Executor) - Constructor for class org.reactivestreams.example.unicast.AsyncIterablePublisher
 
AsyncIterablePublisher(Iterable<T>, Executor) - Constructor for class org.reactivestreams.example.unicast.AsyncIterablePublisher
 
AsyncSubscriber<T> - Class in org.reactivestreams.example.unicast
AsyncSubscriber is an implementation of Reactive Streams `Subscriber`, it runs asynchronously (on an Executor), requests one element at a time, and invokes a user-defined method to process each element.
AsyncSubscriber(Executor) - Constructor for class org.reactivestreams.example.unicast.AsyncSubscriber
 

I

InfiniteIncrementNumberPublisher - Class in org.reactivestreams.example.unicast
 
InfiniteIncrementNumberPublisher(Executor) - Constructor for class org.reactivestreams.example.unicast.InfiniteIncrementNumberPublisher
 

N

NumberIterablePublisher - Class in org.reactivestreams.example.unicast
 
NumberIterablePublisher(int, int, Executor) - Constructor for class org.reactivestreams.example.unicast.NumberIterablePublisher
 

O

onComplete() - Method in class org.reactivestreams.example.unicast.AsyncSubscriber
 
onComplete() - Method in class org.reactivestreams.example.unicast.SyncSubscriber
 
onError(Throwable) - Method in class org.reactivestreams.example.unicast.AsyncSubscriber
 
onError(Throwable) - Method in class org.reactivestreams.example.unicast.SyncSubscriber
 
onNext(T) - Method in class org.reactivestreams.example.unicast.AsyncSubscriber
 
onNext(T) - Method in class org.reactivestreams.example.unicast.SyncSubscriber
 
onSubscribe(Subscription) - Method in class org.reactivestreams.example.unicast.AsyncSubscriber
 
onSubscribe(Subscription) - Method in class org.reactivestreams.example.unicast.SyncSubscriber
 
org.reactivestreams.example.unicast - package org.reactivestreams.example.unicast
 

R

RangePublisher - Class in org.reactivestreams.example.unicast
A synchronous implementation of the Publisher that can be subscribed to multiple times and each individual subscription will receive range of monotonically increasing integer values on demand.
RangePublisher(int, int) - Constructor for class org.reactivestreams.example.unicast.RangePublisher
Constructs a RangePublisher instance with the given start and count values that yields a sequence of [start, start + count).
run() - Method in class org.reactivestreams.example.unicast.AsyncSubscriber
 

S

subscribe(Subscriber<? super Integer>) - Method in class org.reactivestreams.example.unicast.RangePublisher
 
subscribe(Subscriber<? super T>) - Method in class org.reactivestreams.example.unicast.AsyncIterablePublisher
 
SyncSubscriber<T> - Class in org.reactivestreams.example.unicast
SyncSubscriber is an implementation of Reactive Streams `Subscriber`, it runs synchronously (on the Publisher's thread) and requests one element at a time and invokes a user-defined method to process each element.
SyncSubscriber() - Constructor for class org.reactivestreams.example.unicast.SyncSubscriber
 

W

whenComplete() - Method in class org.reactivestreams.example.unicast.AsyncSubscriber
 
whenError(Throwable) - Method in class org.reactivestreams.example.unicast.AsyncSubscriber
 
whenNext(T) - Method in class org.reactivestreams.example.unicast.AsyncSubscriber
 
whenNext(T) - Method in class org.reactivestreams.example.unicast.SyncSubscriber
 
A I N O R S W 
All Classes All Packages