public interface CompletableOperator extends java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
Completable
.
Logically an operator sits between a Completable
and a CompletableSource.Subscriber
and hence it has two
responsibilities:
Completable
on which this operator is applied.CompletableSource.Subscriber
that subscribes to this operator.Function
that takes a CompletableSource.Subscriber
and returns a
CompletableSource.Subscriber
.
The CompletableSource.Subscriber
that is passed to this Function
is the one that has subscribed to this operator.
The CompletableSource.Subscriber
that is returned by this Function
is the one that should be used to subscribe to the
Completable
on which this operator is applied.Modifier and Type | Method and Description |
---|---|
CompletableSource.Subscriber |
apply(CompletableSource.Subscriber subscriber)
Implementation of this operator.
|
CompletableSource.Subscriber apply(CompletableSource.Subscriber subscriber)
CompletableOperator
for definition of an operator.apply
in interface java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
subscriber
- CompletableSource.Subscriber
that subscribed to this operator.CompletableSource.Subscriber
that is used to subscribe to the Completable
that this operator is applied to.