|
|
|
@ -30,7 +30,7 @@ public interface StreamReadArgs {
|
|
|
|
|
/**
|
|
|
|
|
* Defines stream data size limit.
|
|
|
|
|
*
|
|
|
|
|
* @param count - stream data size limit
|
|
|
|
|
* @param count stream data size limit
|
|
|
|
|
* @return arguments object
|
|
|
|
|
*/
|
|
|
|
|
StreamReadArgs count(int count);
|
|
|
|
@ -38,7 +38,7 @@ public interface StreamReadArgs {
|
|
|
|
|
/**
|
|
|
|
|
* Defines time interval to wait for stream data availability.
|
|
|
|
|
*
|
|
|
|
|
* @param timeout - timeout duration
|
|
|
|
|
* @param timeout timeout duration
|
|
|
|
|
* @return arguments object
|
|
|
|
|
*/
|
|
|
|
|
StreamReadArgs timeout(Duration timeout);
|
|
|
|
@ -47,7 +47,7 @@ public interface StreamReadArgs {
|
|
|
|
|
* Defines last stream id received from current Stream.
|
|
|
|
|
* Read stream data with ids greater than defined id.
|
|
|
|
|
*
|
|
|
|
|
* @param id0 - last stream id of current stream
|
|
|
|
|
* @param id0 last stream id of current stream
|
|
|
|
|
* @return arguments object
|
|
|
|
|
*/
|
|
|
|
|
static StreamReadArgs greaterThan(StreamMessageId id0) {
|
|
|
|
|