Class InfiniteHelperPublisher<T>
- java.lang.Object
-
- org.reactivestreams.example.unicast.AsyncIterablePublisher<T>
-
- org.reactivestreams.tck.flow.support.InfiniteHelperPublisher<T>
-
- All Implemented Interfaces:
Publisher<T>
public class InfiniteHelperPublisher<T> extends AsyncIterablePublisher<T>
-
-
Constructor Summary
Constructors Constructor Description InfiniteHelperPublisher(Function<java.lang.Integer,T> create, java.util.concurrent.Executor executor)
-
Method Summary
-
Methods inherited from class org.reactivestreams.example.unicast.AsyncIterablePublisher
subscribe
-
-