T
- The argument typepublic class AsyncSingleResultPublisher<T> extends Object implements Publisher<T>
Publisher
that uses an ExecutorService
to emit a single result.Constructor and Description |
---|
AsyncSingleResultPublisher(ExecutorService executor,
Supplier<T> supplier)
Constructor.
|
AsyncSingleResultPublisher(Supplier<T> supplier)
Constructor.
|
public AsyncSingleResultPublisher(ExecutorService executor, Supplier<T> supplier)
executor
- executorsupplier
- type of supplierpublic final void subscribe(Subscriber<? super T> subscriber)