io.servicetalk.concurrent.api

Interface PublisherToSingleOperator<T,R>

Type Parameters:

T - Type of items emitted by the Publisher this operator is applied.

R - Type of items emitted by this operator.

All Superinterfaces:

java.util.function.Function<SingleSource.Subscriber<? super R>,PublisherSource.Subscriber<? super T>>

public interface PublisherToSingleOperator<T,R>
extends java.util.function.Function<SingleSource.Subscriber<? super R>,PublisherSource.Subscriber<? super T>>

An operator contract for a Publisher to Single conversion. Logically an operator sits between a Publisher and a PublisherSource.Subscriber and hence it has two responsibilities:

• Subscribe to the Publisher on which this operator is applied.
• Accept a SingleSource.Subscriber which is converted to a PublisherSource.Subscriber that subscribes to this operator.

So, an operator can be defined as a Function that takes a SingleSource.Subscriber and returns a PublisherSource.Subscriber. The SingleSource.Subscriber that is passed to this Function is the one that has subscribed to the Single operator. The PublisherSource.Subscriber that is returned by this Function is the one that should be used to subscribe to the Publisher on which this operator is applied.

Method Summary

Modifier and Type	Method and Description
PublisherSource.Subscriber<? super T>	apply(SingleSource.Subscriber<? super R> subscriber) Implementation of this operator.

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Method Detail

apply

PublisherSource.Subscriber<? super T> apply(SingleSource.Subscriber<? super R> subscriber)

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

Specified by:

apply in interface java.util.function.Function<SingleSource.Subscriber<? super R>,PublisherSource.Subscriber<? super T>>

Parameters:

subscriber - SingleSource.Subscriber that subscribed to this operator.

Returns:

PublisherSource.Subscriber that is used to subscribe to the Publisher that this operator is applied to.