Class InfiniteIncrementNumberPublisher
- java.lang.Object
-
- org.reactivestreams.example.unicast.AsyncIterablePublisher<java.lang.Integer>
-
- org.reactivestreams.example.unicast.InfiniteIncrementNumberPublisher
-
- All Implemented Interfaces:
Publisher<java.lang.Integer>
public class InfiniteIncrementNumberPublisher extends AsyncIterablePublisher<java.lang.Integer>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.reactivestreams.example.unicast.AsyncIterablePublisher
AsyncIterablePublisher.Cancel, AsyncIterablePublisher.Request, AsyncIterablePublisher.Send, AsyncIterablePublisher.Signal, AsyncIterablePublisher.Subscribe, AsyncIterablePublisher.SubscriptionImpl
-
-
Constructor Summary
Constructors Constructor Description InfiniteIncrementNumberPublisher(java.util.concurrent.Executor executor)
-
Method Summary
-
Methods inherited from class org.reactivestreams.example.unicast.AsyncIterablePublisher
subscribe
-
-