Package io.smallrye.mutiny.streams.operators

Interface ProcessingStage<I,O>

Type Parameters:
I - type of the received items
O - type of the emitted items
All Superinterfaces:
Function<io.smallrye.mutiny.Multi<I>,io.smallrye.mutiny.Multi<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 ProcessingStage<I,O> extends Function<io.smallrye.mutiny.Multi<I>,io.smallrye.mutiny.Multi<O>>
Defines a processing stage - so a stream transformation.
Author:
Clement Escoffier

  • Method Summary

    Modifier and Type
    Method
    Description
    io.smallrye.mutiny.Multi<O>
    apply(io.smallrye.mutiny.Multi<I> source)
    Adapts the streams.

    Methods inherited from interface java.util.function.Function

    andThen, compose

  • Method Details

    • apply

      io.smallrye.mutiny.Multi<O> apply(io.smallrye.mutiny.Multi<I> source)
      Adapts the streams.
      Specified by:
      apply in interface Function<I,O>
      Parameters:
      source - the input stream, must not be null
      Returns:
      the adapted stream, must not be null