Interface ReactiveRedisConnection

All Superinterfaces:
AutoCloseable, Closeable
All Known Subinterfaces:

public interface ReactiveRedisConnection extends Closeable
Redis connection using reactive infrastructure declaring entry points for reactive command execution.

ReactiveRedisConnection is typically implemented by a stateful object that requires to be closed once it is no longer required.

Commands can be either executed by passing plain arguments like key, value or wrapped inside a command stream. Streaming command execution accepts Publisher of a particular ReactiveRedisConnection.Command. Commands are executed at the time their emission.

Arguments are binary-safe by using ByteBuffer arguments. Expect ByteBuffer to be consumed by ReactiveRedisConnection invocation or during execution. Any ByteBuffer used as method parameter should not be altered after invocation.

Christoph Strobl, Mark Paluch
See Also: