Interface ReadOnlyStore<K extends Comparable<K>,​V>

    • Method Detail

      • find

        Mono<V> find​(K id)
        Attempts to find the value associated with the provided id.
        Parameters:
        id - The id to search with.
        Returns:
        A mono, which may or may not contain an associated object.
      • findInRange

        Flux<V> findInRange​(K start,
                            K end)
        Retrieves all stored values with ids within a provided range.
        Parameters:
        start - The starting key (inclusive).
        end - The ending key (exclusive).
        Returns:
        The stream of values with ids within the provided range.
      • count

        Mono<Long> count()
        Retrieves the amount of stored values in the data source currently.
        Returns:
        A mono which provides the amount of stored values.
      • keys

        Flux<K> keys()
        Gets a stream of all keys in the data source.
        Returns:
        The stream of keys stored.
      • values

        Flux<V> values()
        Gets a stream of all values in the data source.
        Returns:
        The stream of values stored.
      • entries

        default Flux<Tuple2<K,​V>> entries()
        Gets a stream of all entries in the data source.
        Returns:
        The stream of all entries stored.