Class InfiniteIncrementNumberPublisher

java.lang.Object

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

org.reactivestreams.example.unicast.InfiniteIncrementNumberPublisher

All Implemented Interfaces:

Publisher<Integer>

public class InfiniteIncrementNumberPublisher
extends AsyncIterablePublisher<Integer>

Nested Class Summary

Nested classes/interfaces inherited from class AsyncIterablePublisher

AsyncIterablePublisher.Cancel, AsyncIterablePublisher.Request, AsyncIterablePublisher.Send, AsyncIterablePublisher.Signal, AsyncIterablePublisher.Subscribe, AsyncIterablePublisher.SubscriptionImpl

Constructor Summary

Constructors

Constructor	Description
InfiniteIncrementNumberPublisher(Executor executor)

Method Summary

Methods inherited from class AsyncIterablePublisher

subscribe

Methods inherited from class Object

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

Constructor Details

InfiniteIncrementNumberPublisher

public InfiniteIncrementNumberPublisher(Executor executor)