public class InfiniteHelperPublisher<T> extends org.reactivestreams.example.unicast.AsyncIterablePublisher<T>
Constructor | 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)