Reader

Value Members

1. final def !=(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

2. final def !=(arg0: Any): Boolean

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

5. final def ==(arg0: Any): Boolean

   Definition Classes

   Any

6. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. def decodeHeader(reqRecord: RequestRecord, buf: Buf): Future[ResponsePacket]

   Decodes a ReplyHeader from a Buf.

   Decodes a ReplyHeader from a Buf.

   reqRecord

   a Request Record

   buf

   a Buf to decode

   returns

   Future[ResponsePacket]

9. def decodeResponse[T <: Response](reqRecord: RequestRecord, buf: Buf, responseDecoder: (Buf) ⇒ Try[(T, Buf)]): Future[ResponsePacket]

   Decodes a response with a Buf using a response decoder.

   Decodes a response with a Buf using a response decoder.

   T

   the response's type

   reqRecord

   a request record

   buf

   the Buf to decode

   responseDecoder

   a response decoder

   returns

   a Future[ResponsePacket]

10. final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

11. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

12. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

13. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

14. def hashCode(): Int

    Definition Classes

    AnyRef → Any

15. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

16. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

17. final def notify(): Unit

    Definition Classes

    AnyRef

18. final def notifyAll(): Unit

    Definition Classes

    AnyRef

19. def read(pendingRequest: Option[(RequestRecord, Promise[RepPacket])], buffer: Buf): Future[ResponsePacket]

    This function will try to decode the buffer depending if a request is waiting for a response or not.

    This function will try to decode the buffer depending if a request is waiting for a response or not. In case there is a request, it will try to decode with readFromRequest, if an exception is thrown then it will try again with readFromHeader.

    pendingRequest

    expected request description

    buffer

    current buffer

    returns

20. def readFromRequest(req: (RequestRecord, Promise[RepPacket]), buf: Buf): Try[Future[ResponsePacket]]

    If a request is expected, this function will be called first the expected response's opCode is matched, so that we have the correct way to decode.

    If a request is expected, this function will be called first the expected response's opCode is matched, so that we have the correct way to decode. The header is decoded first, the resulting header is checked with checkAssociation to make sure both xids are equal. The body is decoded next and sent with the header in a Future. If any exception is thrown then the readFromHeader will be called.

    req

    expected request

    buf

    current buffer reader

    returns

    a Try of Future[ResponsePacket]

21. def readNotification(buf: Buf): Try[Future[ResponsePacket]]

    Decodes a watch event from a Buf

    Decodes a watch event from a Buf

    buf

    a Buf to decode

    returns

    a Try of Future[ResponsePacket]

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

    Definition Classes

    AnyRef

23. def toString(): String

    Definition Classes

    AnyRef → Any

24. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

26. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )