Interface StreamReadArgs


  • public interface StreamReadArgs
    Arguments object for RStream.read() methods.
    Author:
    Nikita Koksharov
    • Method Detail

      • count

        StreamReadArgs count​(int count)
        Defines stream data size limit.
        Parameters:
        count - - stream data size limit
        Returns:
        arguments object
      • timeout

        StreamReadArgs timeout​(Duration timeout)
        Defines time interval to wait for stream data availability.
        Parameters:
        timeout - - timeout duration
        Returns:
        arguments object
      • greaterThan

        static StreamReadArgs greaterThan​(StreamMessageId id0)
        Defines last stream id received from current Stream. Read stream data with ids greater than defined id.
        Parameters:
        id0 - - last stream id of current stream
        Returns:
        arguments object