public final class AutoOnSubscribeCompletableSubscriberFunction extends java.lang.Object implements java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
CompletableSource.Subscriber.onSubscribe(Cancellable)
automatically, sending a delegating Cancellable
.
Returns a CompletableSource.Subscriber
which, upon receiving CompletableSource.Subscriber.onSubscribe(Cancellable)
, uses the received
Cancellable
to delegate to.Constructor and Description |
---|
AutoOnSubscribeCompletableSubscriberFunction() |
Modifier and Type | Method and Description |
---|---|
CompletableSource.Subscriber |
apply(CompletableSource.Subscriber subscriber) |
public AutoOnSubscribeCompletableSubscriberFunction()
public CompletableSource.Subscriber apply(CompletableSource.Subscriber subscriber)
apply
in interface java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>