Module io.inverno.mod.redis

Package io.inverno.mod.redis.operations

Interface RedisStreamReactiveOperations.StreamXreadBuilder<A,B>

Type Parameters:

A - key type

B - value type

Enclosing interface:

RedisStreamReactiveOperations<A,B>

public static interface RedisStreamReactiveOperations.StreamXreadBuilder<A,B>

XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] id [id ...]

Since:

1.4

Author:

Jeremy Kuhn

Method Summary

Modifier and Type	Method	Description
RedisStreamReactiveOperations.StreamXreadBuilder<A,B>	block(long milliseconds)
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	build(A key, String messageId)
Flux<RedisStreamReactiveOperations.StreamMessage<A,B>>	build(Consumer<RedisStreamReactiveOperations.StreamStreams<A>> streams)
RedisStreamReactiveOperations.StreamXreadBuilder<A,B>	count(long count)

Method Details

count

RedisStreamReactiveOperations.StreamXreadBuilder<A,B> count(long count)

Parameters:

count -

Returns:

block

RedisStreamReactiveOperations.StreamXreadBuilder<A,B> block(long milliseconds)

Parameters:

milliseconds -

Returns:

build

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> build(A key,
 String messageId)

Parameters:

key -

messageId -

Returns:

build

Flux<RedisStreamReactiveOperations.StreamMessage<A,B>> build(Consumer<RedisStreamReactiveOperations.StreamStreams<A>> streams)

Parameters:

streams -

Returns: