Interface ReactiveAggregationOperation.TerminatingAggregationOperation<T>

Enclosing interface:
ReactiveAggregationOperation

public static interface ReactiveAggregationOperation.TerminatingAggregationOperation<T>
Trigger execution by calling one of the terminating methods.
  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Flux<T>
    all()
    Apply pipeline operations as specified and stream all matching elements.
  • Method Details

    • all

      reactor.core.publisher.Flux<T> all()
      Apply pipeline operations as specified and stream all matching elements.
      Returns:
      a Flux streaming all matching elements. Never null.