class
      
      
        RedisReplyDecoder extends Actor
      
      
      
          
        
      
      
        
        
              Instance Constructors
              - 
      
      
      
      
        
        new
      
      
        RedisReplyDecoder()
      
        
 
        
              Type Members
              - 
      
      
      
      
          
 
        
        
              Value Members
              - 
      
      
      
      
        final 
        def
      
      
        !=(arg0: Any): Boolean
      
        
- 
      
      
      
      
        final 
        def
      
      
        ##(): Int
      
        
- 
      
      
      
      
        final 
        def
      
      
        ==(arg0: Any): Boolean
      
        
- 
      
      
      
      
        
        def
      
      
        aroundPostRestart(reason: Throwable): Unit
      
        
- 
      
      
      
      
        
        def
      
      
        aroundPostStop(): Unit
      
        
- 
      
      
      
      
        
        def
      
      
        aroundPreRestart(reason: Throwable, message: Option[Any]): Unit
      
        
- 
      
      
      
      
        
        def
      
      
        aroundPreStart(): Unit
      
        
- 
      
      
      
      
        
        def
      
      
        aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit
      
        
- 
      
      
      
      
        final 
        def
      
      
        asInstanceOf[T0]: T0
      
        
- 
      
      
      
      
        
        var
      
      
        bufferRead: ByteString
      
        
- 
      
      
      
      
        
        def
      
      
        clone(): AnyRef
      
        
- 
      
      
      
      
        implicit 
        val
      
      
        context: ActorContext
      
        
- 
      
      
      
      
        
        def
      
      
        decodeRedisReply(operation: Operation[_, _], bs: ByteString): Option[(Any, ByteString)]
      
        
- 
      
      
      
      
        
        def
      
      
        decodeReplies(dataByteString: ByteString): Unit
      
        
- 
      
      
      
      
          
- 
      
      
      
      
          
- 
      
      
      
      
        
        def
      
      
        finalize(): Unit
      
        
- 
      
      
      
      
        final 
        def
      
      
        getClass(): Class[_]
      
        
- 
      
      
      
      
        
        def
      
      
        hashCode(): Int
      
        
- 
      
      
      
      
        final 
        def
      
      
        isInstanceOf[T0]: Boolean
      
        
- 
      
      
      
      
        
        val
      
      
        log: LoggingAdapter
      
        
- 
      
      
      
      
          
- 
      
      
      
      
        final 
        def
      
      
        notify(): Unit
      
        
- 
      
      
      
      
        final 
        def
      
      
        notifyAll(): Unit
      
        
- 
      
      
      
      
        
        def
      
      
        postRestart(reason: Throwable): Unit
      
        
- 
      
      
      
      
        
        def
      
      
        postStop(): Unit
      
        
- 
      
      
      
      
        
        def
      
      
        preRestart(reason: Throwable, message: Option[Any]): Unit
      
        
- 
      
      
      
      
        
        def
      
      
        preStart(): Unit
      
        
- 
      
      
      
      
        
        val
      
      
        queuePromises: Queue[Operation[_, _]]
      
        
- 
      
      
      
      
          
- 
      
      
      
      
        implicit final 
        val
      
      
        self: ActorRef
      
        
- 
      
      
      
      
        final 
        def
      
      
        sender(): ActorRef
      
        
- 
      
      
      
      
        
        def
      
      
        supervisorStrategy: SupervisorStrategy
      
        
- 
      
      
      
      
        final 
        def
      
      
        synchronized[T0](arg0: ⇒ T0): T0
      
        
- 
      
      
      
      
        
        def
      
      
        toString(): String
      
        
- 
      
      
      
      
        
        def
      
      
        unhandled(message: Any): Unit
      
        
- 
      
      
      
      
        final 
        def
      
      
        wait(): Unit
      
        
- 
      
      
      
      
        final 
        def
      
      
        wait(arg0: Long, arg1: Int): Unit
      
        
- 
      
      
      
      
        final 
        def
      
      
        wait(arg0: Long): Unit
      
      