Interface ReactiveAggregationOperation.TerminatingAggregationOperation<T>
- Enclosing interface:
- ReactiveAggregationOperation
public static interface ReactiveAggregationOperation.TerminatingAggregationOperation<T>
Trigger execution by calling one of the terminating methods.
-
Method Summary
-
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.
-