Interface StreamableOperator<T,R>

Type Parameters:

T - the value type of the upstream

R - the value type of the downstream

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface StreamableOperator<@NonNull T, @NonNull R>

Interface to map/wrap an upstream Streamer to an downstream Streamer.

Since:

4.0.0

Method Summary

Modifier and Type	Method	Description
@NonNull Streamer<? extends R>	apply(@NonNull StreamerCancellation container, @NonNull Streamer<? extends @NonNull T> streamer)	Applies a function to the upstream Streamer and returns a new downstream Streamer.

Method Details

apply

@NonNull
@NonNull Streamer<? extends R> apply(@NonNull
 @NonNull StreamerCancellation container,
 @NonNull
 @NonNull Streamer<? extends @NonNull T> streamer)
                              throws Throwable

Applies a function to the upstream Streamer and returns a new downstream Streamer.

Parameters:

container - the StreamerCancellation handling the cancellation propagation for the downstream

streamer - the upstream Streamer instance

Returns:

the downstream Streamer instance

Throws:

Throwable - on failure