public class InfiniteHelperPublisher<T> extends org.reactivestreams.example.unicast.AsyncIterablePublisher<T>
Constructor and Description |
---|
InfiniteHelperPublisher(Function<java.lang.Integer,T> create,
java.util.concurrent.Executor executor) |
public InfiniteHelperPublisher(Function<java.lang.Integer,T> create, java.util.concurrent.Executor executor)