Class ReactiveBatchHelper


  • @Uncommitted
    public class ReactiveBatchHelper
    extends Object
    This helper class provides methods that make performing batch operations easy and comfortable.
    • Constructor Detail

      • ReactiveBatchHelper

        public ReactiveBatchHelper()
    • Method Detail

      • getIfExists

        @Uncommitted
        public static Mono<Map<String,​GetResult>> getIfExists​(Collection collection,
                                                                    Collection<String> ids)
        First checks if the given IDs exist and if so fetches their contents.

        Please take into consideration when using this API that it only makes sense to use it if of the many ids provided only a small subset comes back. (So let's say you give it 1000 IDs but you only expect 50 to be there or so). Otherwise if all are most of them are there, just use a bulk get with the reactive API directly - you won't see much benefit in this case.

        Parameters:
        collection - the collection to perform the fetch on.
        ids - the document IDs to fetch.
        Returns:
        a Map of the document IDs as the key and the result (if found).
      • exists

        @Uncommitted
        public static Flux<String> exists​(Collection collection,
                                          Collection<String> ids)
        Returns a flux of ids for the documents that exist.

        Note that you usually only want to use this API if you really need to bulk check exists on many documents at once, for all other use cases we recommend trying the regular, supported APIs first (i.e. using ReactiveCollection.exists(String)).

        Parameters:
        collection - the collection to perform the exists checks on.
        ids - the document IDs to check.
        Returns:
        a flux of all the ids that are found.