Class StoreView<K extends Comparable<K>,​V>

    • Constructor Detail

      • StoreView

        public StoreView​(Store<K,​V> backing)
    • Method Detail

      • find

        public 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

        public 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

        public 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

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

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

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