Package io.smallrye.mutiny.streams.operators

Interface TerminalStage<I,O>

All Superinterfaces:

Function<Multi<I>,CompletionStage<O>>

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 TerminalStage<I,O>
extends Function<Multi<I>,CompletionStage<O>>

Defines a terminal stage - so a stream subscription and observation.

Author:

Clement Escoffier

Method Summary

Modifier and Type	Method	Description
CompletionStage<O>	apply(Multi<I> multi)	Creates the CompletionStage called when the embedded logic has completed or failed.

Methods inherited from interface java.util.function.Function

andThen, compose

Method Details

apply

CompletionStage<O> apply(Multi<I> multi)

Creates the CompletionStage called when the embedded logic has completed or failed.

Specified by:

apply in interface Function<I,O>

Parameters:

multi - the observed / subscribed stream

Returns:

the asynchronous result