RedisWorkerIO

abstract def onClosingConnectionClosed(): Unit

abstract def onConnectWrite(): ByteString

abstract def onConnectionClosed(): Unit

abstract def onDataReceived(dataByteString: ByteString): Unit

abstract def onDataReceivedOnClosingConnection(dataByteString: ByteString): Unit

abstract def onWriteSent(): Unit

abstract def writing: Receive

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

val address: InetSocketAddress

final def asInstanceOf[T0]: T0

val bufferWrite: ByteStringBuilder

def cleanState(): Unit

def clone(): AnyRef

def connected: Receive

def connecting: Receive

implicit val context: ActorContext

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

def initConnectedBuffer(): Unit

final def isInstanceOf[T0]: Boolean

val log: LoggingAdapter

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def onAddressChanged(addr: InetSocketAddress): Unit

def onConnected(cmd: Connected): Unit

def onConnectedCommandFailed(commandFailed: CommandFailed): Unit

O/S buffer was full Maybe to much data in the Command ?

def onConnectingCommandFailed(cmdFailed: CommandFailed): Unit

def onConnectionClosed(c: ConnectionClosed): Unit

def postRestart(reason: Throwable): Unit

def postStop(): Unit

def preRestart(reason: Throwable, message: Option[Any]): Unit

def preStart(): Unit

var readyToWrite: Boolean

def receive: PartialFunction[Any, Unit]

def reconnect(): Unit

def reconnectDuration: FiniteDuration

def restartConnection(): Unit

def scheduleReconnect(): Unit

implicit final val self: ActorRef

final def sender: ActorRef

def supervisorStrategy: SupervisorStrategy

final def synchronized[T0](arg0: ⇒ T0): T0

val tcp: ActorRef

var tcpWorker: ActorRef

def toString(): String

def tryInitialWrite(): Unit

def tryWrite(): Unit

def unhandled(message: Any): Unit

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def write(byteString: ByteString): Unit