Uses of Class
org.springframework.data.redis.connection.ReactiveStreamCommands.ReadCommand

Packages that use ReactiveStreamCommands.ReadCommand

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.

Uses of ReactiveStreamCommands.ReadCommand in org.springframework.data.redis.connection

Methods in org.springframework.data.redis.connection that return ReactiveStreamCommands.ReadCommand

Modifier and Type	Method	Description
ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.as(Consumer consumer)	Applies a Consumer.
static ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBuffer> streamOffset)	Creates a new ReactiveStreamCommands.ReadCommand given a StreamOffset.
static ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBuffer>... streamOffsets)	Creates a new ReactiveStreamCommands.ReadCommand given a StreamOffsets.
ReactiveStreamCommands.ReadCommand	ReactiveStreamCommands.ReadCommand.withOptions(StreamReadOptions options)	Applies the given StreamReadOptions.

Methods in org.springframework.data.redis.connection that return types with arguments of type ReactiveStreamCommands.ReadCommand

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	ReactiveStreamCommands.read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)	Read records from one or more StreamOffsets.

Method parameters in org.springframework.data.redis.connection with type arguments of type ReactiveStreamCommands.ReadCommand

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	ReactiveStreamCommands.read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)	Read records from one or more StreamOffsets.