Publisher that uses an ExecutorService to emit a single result.CompletableFuture to a Publisher.Subscriber that tracks completion state using a AtomicBoolean.Subscriber.Subscriber.SingleSubscriberProcessor.doOnComplete() completes.SingleSubscriberProcessor.doOnError(Throwable) completes.SingleSubscriberProcessor.doOnSubscribe(Subscription) completes.Subscriber.onComplete().Subscriber.onComplete().Subscriber.onError(Throwable).Subscriber.onError(Throwable).Subscriber.onNext(Object).Subscriber.onNext(Object).Subscriber.onSubscribe(Subscription).Subscriber.onSubscribe(Subscription).Publisher.subscribe(Subscriber).Publisher.subscribe(Subscriber).Publisher that completes without emitting any items.Publisher from a CompletableFuture.Publisher from a CompletableFuture.Subscriber.Subscriber.Publisher that emits a fixed single value.Publisher that emits a fixed single value.Publisher in response to requests to Subscription.request(long).Subscriber.Publisher instances.class.TypeInformationProvider for reactive streams.Publisher.Processor that only allows a single SubscriberPublisher that only allows a single Subscriber.Processor designed to be used within a single thread and manage
back pressure state.Subscriber designed to be used by a single thread that buffers incoming data for the purposes of managing
back pressure.TypedSubscriber for the given Argument.