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