public XReadArgs block(Duration timeout) {

        LettuceAssert.notNull(timeout, "Block timeout must not be null");

        return block(timeout.toMillis());
    }
public XReadArgs block ( Duration timeout ) { LettuceAssert . notNull ( timeout , "Block timeout must not be null" ) ; return block ( timeout . toMillis ( ) ) ; }
Perform a blocking read and wait up to a {@link Duration timeout} for a new stream message.

@param timeout max time to wait.
@return {@code this}.