io.servicetalk.concurrent.api

Interface CompletableOperator

All Superinterfaces:

java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>

public interface CompletableOperator
extends java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>

An operator contract for a Completable. Logically an operator sits between a Completable and a CompletableSource.Subscriber and hence it has two responsibilities:

• Subscribe to the Completable on which this operator is applied.
• Accept a CompletableSource.Subscriber that subscribes to this operator.

So, an operator can be defined as a 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.

Method Summary

Modifier and Type	Method and Description
CompletableSource.Subscriber	apply(CompletableSource.Subscriber subscriber) Implementation of this operator.

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Method Detail

apply

CompletableSource.Subscriber apply(CompletableSource.Subscriber subscriber)

Implementation of this operator. See CompletableOperator for definition of an operator.

Specified by:

apply in interface java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>

Parameters:

subscriber - CompletableSource.Subscriber that subscribed to this operator.

Returns:

CompletableSource.Subscriber that is used to subscribe to the Completable that this operator is applied to.