Uses of Class
org.springframework.data.redis.connection.stream.StreamReadOptions

Packages that use StreamReadOptions

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
org.springframework.data.redis.connection.stream	Data structures and interfaces to interact with Redis Streams.
org.springframework.data.redis.core	Core package for integrating Redis with Spring concepts.

Uses of StreamReadOptions in org.springframework.data.redis.connection

Methods in org.springframework.data.redis.connection that return StreamReadOptions

Modifier and Type	Method and Description
StreamReadOptions	ReactiveStreamCommands.ReadCommand.getReadOptions()

Methods in org.springframework.data.redis.connection with parameters of type StreamReadOptions

Modifier and Type	Method and Description
ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.withOptions(StreamReadOptions options) Applies the given StreamReadOptions.
List<ByteRecord>	DefaultStringRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams)
default List<ByteRecord>	DefaultedRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated. in favor of RedisConnection.streamCommands()}.
List<ByteRecord>	RedisStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or more StreamOffsets.
default reactor.core.publisher.Flux<ByteBufferRecord>	ReactiveStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or more StreamOffsets.
List<StringRecord>	DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String>... streams)
List<StringRecord>	StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or more StreamOffsets.
default List<StringRecord>	StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or more StreamOffsets.
List<ByteRecord>	DefaultStringRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams)
default List<ByteRecord>	DefaultedRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated. in favor of RedisConnection.streamCommands()}.
List<ByteRecord>	RedisStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or more StreamOffsets using a consumer group.
default reactor.core.publisher.Flux<ByteBufferRecord>	ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams) Read records from one or more StreamOffsets using a consumer group.
List<StringRecord>	DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams)
List<StringRecord>	StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or more StreamOffsets using a consumer group.
default List<StringRecord>	StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or more StreamOffsets using a consumer group.

Constructors in org.springframework.data.redis.connection with parameters of type StreamReadOptions

Constructor and Description
ReadCommand(List<StreamOffset<ByteBuffer>> streamOffsets, StreamReadOptions readOptions, Consumer consumer)

Uses of StreamReadOptions in org.springframework.data.redis.connection.stream

Methods in org.springframework.data.redis.connection.stream that return StreamReadOptions

Modifier and Type	Method and Description
StreamReadOptions	StreamReadOptions.autoAcknowledge() Enable auto-acknowledgement by setting the NOACK flag when reading in the context of a consumer group.
StreamReadOptions	StreamReadOptions.block(Duration timeout) Use a blocking read and supply the timeout after which the call will terminate if no message was read.
StreamReadOptions	StreamReadOptions.count(long count) Limit the number of messages returned per stream.
static StreamReadOptions	StreamReadOptions.empty() Creates an empty StreamReadOptions instance.
StreamReadOptions	StreamReadOptions.noack() Enable auto-acknowledgement by setting the NOACK flag when reading in the context of a consumer group.

Uses of StreamReadOptions in org.springframework.data.redis.core

Methods in org.springframework.data.redis.core with parameters of type StreamReadOptions

Modifier and Type	Method and Description
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or more StreamOffsets using a consumer group as ObjectRecord.
default <V> List<ObjectRecord<K,V>>	StreamOperations.read(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or more StreamOffsets as ObjectRecord.
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>>	ReactiveStreamOperations.read(Class<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or more StreamOffsets as ObjectRecord.
List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, ReadOffset readOffset) Read records starting from ReadOffset. using a consumer group.
List<MapRecord<K,HK,HV>>	StreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or more StreamOffsets using a consumer group.
reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or more StreamOffsets using a consumer group.
List<MapRecord<K,HK,HV>>	BoundStreamOperations.read(StreamReadOptions readOptions, ReadOffset readOffset) Read records starting from ReadOffset.
List<MapRecord<K,HK,HV>>	StreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or more StreamOffsets.
reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams) Read records from one or more StreamOffsets.