Uses of Class
org.springframework.data.redis.connection.ReactiveStreamCommands.ReadCommand
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
-
Uses of ReactiveStreamCommands.ReadCommand in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionApplies aConsumer
.ReactiveStreamCommands.ReadCommand.from
(StreamOffset<ByteBuffer> streamOffset) Creates a newReactiveStreamCommands.ReadCommand
given aStreamOffset
.ReactiveStreamCommands.ReadCommand.from
(StreamOffset<ByteBuffer>... streamOffsets) Creates a newReactiveStreamCommands.ReadCommand
given aStreamOffset
s.ReactiveStreamCommands.ReadCommand.withOptions
(StreamReadOptions options) Applies the givenStreamReadOptions
.Modifier and TypeMethodDescriptionreactor.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 moreStreamOffset
s.Modifier and TypeMethodDescriptionreactor.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 moreStreamOffset
s.