Class RangePublisher

java.lang.Object

org.reactivestreams.example.unicast.RangePublisher

All Implemented Interfaces:

Publisher<Integer>

public final class RangePublisher
extends Object
implements Publisher<Integer>

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.

Constructor Summary

Constructors

Constructor	Description
RangePublisher(int start, int count)	Constructs a RangePublisher instance with the given start and count values that yields a sequence of [start, start + count).

Method Summary

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

Methods inherited from class Object

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

Constructor Details

RangePublisher

public RangePublisher(int start,
 int count)

Constructs a RangePublisher instance with the given start and count values that yields a sequence of [start, start + count).

Parameters:

start - the starting value of the range

count - the number of items to emit

Method Details

subscribe

public void subscribe(Subscriber<? super Integer> subscriber)

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<Integer>

Parameters:

subscriber - the Subscriber that will consume signals from this Publisher