Class AsyncIterablePublisher<T>

java.lang.Object

org.reactivestreams.example.unicast.AsyncIterablePublisher<T>

All Implemented Interfaces:

Publisher<T>

Direct Known Subclasses:

HelperPublisher, InfiniteHelperPublisher, InfiniteIncrementNumberPublisher, NumberIterablePublisher

public class AsyncIterablePublisher<T>
extends Object
implements Publisher<T>

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`. NOTE: The code below uses a lot of try-catches to show the reader where exceptions can be expected, and where they are forbidden.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	AsyncIterablePublisher.Cancel
(package private) static final class	AsyncIterablePublisher.Request
(package private) static enum	AsyncIterablePublisher.Send
(package private) static interface	AsyncIterablePublisher.Signal
(package private) static enum	AsyncIterablePublisher.Subscribe
(package private) final class	AsyncIterablePublisher.SubscriptionImpl

Field Summary

Fields

Modifier and Type	Field	Description
private final int	batchSize
private static final int	DEFAULT_BATCHSIZE
private final Iterable<T>	elements
private final Executor	executor

Constructor Summary

Constructors

Constructor	Description
AsyncIterablePublisher(Iterable<T> elements, int batchSize, Executor executor)
AsyncIterablePublisher(Iterable<T> elements, Executor executor)

Method Summary

Modifier and Type	Method	Description
void	subscribe(Subscriber<? super T> s)	Request Publisher to start streaming data.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_BATCHSIZE

private static final int DEFAULT_BATCHSIZE

See Also:

• Constant Field Values

elements

private final Iterable<T> elements

executor

private final Executor executor

batchSize

private final int batchSize

Constructor Details

AsyncIterablePublisher

public AsyncIterablePublisher(Iterable<T> elements,
 Executor executor)

AsyncIterablePublisher

public AsyncIterablePublisher(Iterable<T> elements,
 int batchSize,
 Executor executor)

Method Details

subscribe

public void subscribe(Subscriber<? super T> s)

Description copied from interface: Publisher

Request Publisher to start streaming data.

This is a "factory method" and can be called multiple times, each time starting a new Subscription.

Each Subscription will work for only a single Subscriber.

A Subscriber should only subscribe once to a single Publisher.

If the Publisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber.onError(Throwable).

Specified by:

subscribe in interface Publisher<T>

Parameters:

s - the Subscriber that will consume signals from this Publisher