Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.ReadCommand |
ReactiveStreamCommands.ReadCommand.as(Consumer consumer)
Applies a
Consumer . |
static ReactiveStreamCommands.ReadCommand |
ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBuffer>... streamOffsets)
Creates a new
ReactiveStreamCommands.ReadCommand given a StreamOffset s. |
static ReactiveStreamCommands.ReadCommand |
ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBuffer> streamOffset)
Creates a new
ReactiveStreamCommands.ReadCommand given a StreamOffset . |
ReactiveStreamCommands.ReadCommand |
ReactiveStreamCommands.ReadCommand.withOptions(StreamReadOptions options)
Applies the given
StreamReadOptions . |
Modifier and Type | Method and 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
StreamOffset s. |
Modifier and Type | Method and 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
StreamOffset s. |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.