Package io.servicetalk.concurrent.api

Interface SwitchMapSignal<T>

Type Parameters:

T - Type of the data.

public interface SwitchMapSignal<T>

A signal containing the data from a series of Publishers switched in a serial fashion.

See Also:

• Publisher.switchMap(Function)

Method Summary

Modifier and Type	Method	Description
boolean	isSwitched()	Returns true on the first signal from a new Publisher.
T	onNext()	Get the data that was delivered to PublisherSource.Subscriber.onNext(Object).
static <T, R> Function<T,Publisher<? extends SwitchMapSignal<R>>>	toSwitchFunction(Function<? super T,? extends Publisher<? extends R>> function)	Convert from a regular Function to a Function that emits SwitchMapSignal.

Method Details

isSwitched

boolean isSwitched()

Returns true on the first signal from a new Publisher.

Returns:

true on the first signal from a new Publisher.

onNext

@Nullable
T onNext()

Get the data that was delivered to PublisherSource.Subscriber.onNext(Object).

Returns:

the data that was delivered to PublisherSource.Subscriber.onNext(Object).

toSwitchFunction

static <T,
R>
Function<T,Publisher<? extends SwitchMapSignal<R>>> toSwitchFunction(Function<? super T,? extends Publisher<? extends R>> function)

Convert from a regular Function to a Function that emits SwitchMapSignal.

This function has state, if used in an operator chain use Publisher.defer(Supplier) so the state is unique per each subscribe.

Type Parameters:

T - The input data type.

R - The resulting data type.

Parameters:

function - The original function to convert.

Returns:

a Function that emits SwitchMapSignal.