Package org.springframework.data.mongodb.core

Interface ReactiveMapReduceOperation.TerminatingMapReduce<T>

All Known Subinterfaces:
ReactiveMapReduceOperation.MapReduceWithCollection<T>, ReactiveMapReduceOperation.MapReduceWithProjection<T>, ReactiveMapReduceOperation.MapReduceWithQuery<T>, ReactiveMapReduceOperation.ReactiveMapReduce<T>
Enclosing interface:
ReactiveMapReduceOperation
public static interface ReactiveMapReduceOperation.TerminatingMapReduce<T>
Trigger mapReduce execution by calling one of the terminating methods.
Since:
2.1
Author:
Christoph Strobl

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Flux<T>
    all()
    Get the Flux emitting mapReduce results.

  • Method Details

    • all

      reactor.core.publisher.Flux<T> all()
      Get the Flux emitting mapReduce results.
      Returns:
      a Flux emitting the already mapped operation results.