Package io.smallrye.mutiny.streams.operators

Interface TerminalStage<I,O>

All Superinterfaces:
Function<io.smallrye.mutiny.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<io.smallrye.mutiny.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(io.smallrye.mutiny.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(io.smallrye.mutiny.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