Package org.redisson.spring.data.connection

Class RedissonReactiveStreamCommands

  • All Implemented Interfaces:
    org.springframework.data.redis.connection.ReactiveStreamCommands
    Direct Known Subclasses:
    RedissonReactiveClusterStreamCommands
    public class RedissonReactiveStreamCommands
extends Object
implements org.springframework.data.redis.connection.ReactiveStreamCommands
    Author:
    Nikita Koksharov

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.ReactiveStreamCommands

        org.springframework.data.redis.connection.ReactiveStreamCommands.AcknowledgeCommand, org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord, org.springframework.data.redis.connection.ReactiveStreamCommands.DeleteCommand, org.springframework.data.redis.connection.ReactiveStreamCommands.GroupCommand, org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand, org.springframework.data.redis.connection.ReactiveStreamCommands.ReadCommand, org.springframework.data.redis.connection.ReactiveStreamCommands.TrimCommand

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.ReadCommand,​reactor.core.publisher.Flux<org.springframework.data.redis.connection.stream.ByteBufferRecord>>> read​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.ReadCommand> publisher)  
      static byte[] toByteArray​(ByteBuffer buffer)  
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.AcknowledgeCommand,​Long>> xAck​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.AcknowledgeCommand> publisher)  
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord,​org.springframework.data.redis.connection.stream.RecordId>> xAdd​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord> publisher)  
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.DeleteCommand,​Long>> xDel​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.DeleteCommand> publisher)  
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.GroupCommand,​String>> xGroup​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.GroupCommand> publisher)  
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse<org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand,​Long>> xLen​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand> publisher)  
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand,​reactor.core.publisher.Flux<org.springframework.data.redis.connection.stream.ByteBufferRecord>>> xRange​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand> publisher)  
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand,​reactor.core.publisher.Flux<org.springframework.data.redis.connection.stream.ByteBufferRecord>>> xRevRange​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand> publisher)  
      reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse<org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand,​Long>> xTrim​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.TrimCommand> publisher)  

      • Methods inherited from interface org.springframework.data.redis.connection.ReactiveStreamCommands

        xAck, xAck, xAdd, xAdd, xDel, xDel, xGroup, xGroupCreate, xGroupDelConsumer, xGroupDelConsumer, xGroupDestroy, xLen, xRange, xRange, xRead, xRead, xReadGroup, xReadGroup, xRevRange, xRevRange, xTrim

    • Method Detail

      • xAck

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.AcknowledgeCommand,​Long>> xAck​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.AcknowledgeCommand> publisher)
        Specified by:
        xAck in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • xAdd

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord,​org.springframework.data.redis.connection.stream.RecordId>> xAdd​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord> publisher)
        Specified by:
        xAdd in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • xDel

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.DeleteCommand,​Long>> xDel​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.DeleteCommand> publisher)
        Specified by:
        xDel in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • xLen

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse<org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand,​Long>> xLen​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand> publisher)
        Specified by:
        xLen in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • xRange

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand,​reactor.core.publisher.Flux<org.springframework.data.redis.connection.stream.ByteBufferRecord>>> xRange​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand> publisher)
        Specified by:
        xRange in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • read

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.ReadCommand,​reactor.core.publisher.Flux<org.springframework.data.redis.connection.stream.ByteBufferRecord>>> read​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.ReadCommand> publisher)
        Specified by:
        read in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • xGroup

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.GroupCommand,​String>> xGroup​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.GroupCommand> publisher)
        Specified by:
        xGroup in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • xRevRange

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand,​reactor.core.publisher.Flux<org.springframework.data.redis.connection.stream.ByteBufferRecord>>> xRevRange​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.RangeCommand> publisher)
        Specified by:
        xRevRange in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • xTrim

        public reactor.core.publisher.Flux<org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse<org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand,​Long>> xTrim​(org.reactivestreams.Publisher<org.springframework.data.redis.connection.ReactiveStreamCommands.TrimCommand> publisher)
        Specified by:
        xTrim in interface org.springframework.data.redis.connection.ReactiveStreamCommands

      • toByteArray

        public static byte[] toByteArray​(ByteBuffer buffer)