Packages

c

org.http4s.blaze.http.websocket

WebSocketDecoder

class WebSocketDecoder extends FrameTranscoder with ByteToObjectStage[WebSocketFrame]

Linear Supertypes
ByteToObjectStage[WebSocketFrame], MidStage[ByteBuffer, WebSocketFrame], Head[WebSocketFrame], Tail[ByteBuffer], Stage, FrameTranscoder, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WebSocketDecoder
  2. ByteToObjectStage
  3. MidStage
  4. Head
  5. Tail
  6. Stage
  7. FrameTranscoder
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new WebSocketDecoder(isClient: Boolean, maxBufferSize: Int = 0)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def bufferToFrame(in: ByteBuffer): WebSocketFrame
    Definition Classes
    FrameTranscoder
  6. def bufferToMessage(in: ByteBuffer): Option[WebSocketFrame]

    Method that decodes ByteBuffers to objects.

    Method that decodes ByteBuffers to objects. None reflects not enough data to decode a message Any unused data in the ByteBuffer will be recycled and available for the next read

    in

    ByteBuffer of immediately available data

    returns

    optional message if enough data was available

    Definition Classes
    WebSocketDecoder → ByteToObjectStage
    Annotations
    @throws( ... )
  7. def channelRead(size: Int, timeout: Duration): Future[ByteBuffer]
    Definition Classes
    Tail
  8. final def channelWrite(data: Seq[ByteBuffer], timeout: Duration): Future[Unit]
    Definition Classes
    Tail
  9. def channelWrite(data: Seq[ByteBuffer]): Future[Unit]
    Definition Classes
    Tail
  10. final def channelWrite(data: ByteBuffer, timeout: Duration): Future[Unit]
    Definition Classes
    Tail
  11. def channelWrite(data: ByteBuffer): Future[Unit]
    Definition Classes
    Tail
  12. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  15. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. final def findInboundStage[C <: Stage](clazz: Class[C]): Option[C]
    Definition Classes
    Head
  17. final def findInboundStage(name: String): Option[Stage]
    Definition Classes
    Head
  18. final def findOutboundStage[C <: Stage](clazz: Class[C]): Option[C]
    Definition Classes
    Tail
  19. final def findOutboundStage(name: String): Option[Stage]
    Definition Classes
    Tail
  20. def frameToBuffer(in: WebSocketFrame): Array[ByteBuffer]
    Definition Classes
    FrameTranscoder
  21. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  22. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  23. def inboundCommand(cmd: InboundCommand): Unit
    Definition Classes
    Head → Stage
  24. val isClient: Boolean
    Definition Classes
    FrameTranscoder
  25. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  26. final val logger: Logger
    Attributes
    protected
    Definition Classes
    Stage
  27. val maxBufferSize: Int
    Definition Classes
    WebSocketDecoder → ByteToObjectStage
  28. def messageToBuffer(in: WebSocketFrame): Seq[ByteBuffer]

    Encode objects to buffers

    Encode objects to buffers

    in

    object to decode

    returns

    sequence of ByteBuffers to pass to the head

    Definition Classes
    WebSocketDecoder → ByteToObjectStage
    Annotations
    @throws( ... )
  29. val name: String
    Definition Classes
    WebSocketDecoder → Stage
  30. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  31. final def notify(): Unit
    Definition Classes
    AnyRef
  32. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  33. def outboundCommand(cmd: OutboundCommand): Unit
    Definition Classes
    MidStage → Head
  34. def readRequest(size: Int): Future[WebSocketFrame]
    Definition Classes
    ByteToObjectStage → Head
  35. final def removeStage(implicit ev: =:=[MidStage[ByteBuffer, WebSocketFrame], MidStage[ByteBuffer, ByteBuffer]]): Unit
    Definition Classes
    MidStage
  36. final def replaceInline(stage: MidStage[ByteBuffer, WebSocketFrame]): WebSocketDecoder.this.type
    Definition Classes
    MidStage
  37. final def replaceInline(leafBuilder: LeafBuilder[ByteBuffer], startup: Boolean): WebSocketDecoder.this.type
    Definition Classes
    Tail
  38. final def replaceNext(stage: LeafBuilder[WebSocketFrame]): Tail[WebSocketFrame]
    Definition Classes
    MidStage
  39. final def sendInboundCommand(cmd: InboundCommand): Unit
    Definition Classes
    Head
  40. final def sendOutboundCommand(cmd: OutboundCommand): Unit
    Definition Classes
    Tail
  41. final def spliceAfter(stage: MidStage[WebSocketFrame, WebSocketFrame]): Unit
    Definition Classes
    Head
  42. final def spliceBefore(stage: MidStage[ByteBuffer, ByteBuffer]): Unit
    Definition Classes
    Tail
  43. def stageShutdown(): Unit
    Attributes
    protected
    Definition Classes
    Stage
  44. def stageStartup(): Unit
    Attributes
    protected
    Definition Classes
    Stage
  45. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  46. def toString(): String
    Definition Classes
    AnyRef → Any
  47. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  48. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  50. def writeRequest(data: WebSocketFrame): Future[Unit]
    Definition Classes
    ByteToObjectStage → Head
  51. def writeRequest(data: Seq[WebSocketFrame]): Future[Unit]
    Definition Classes
    ByteToObjectStage → Head

Inherited from ByteToObjectStage[WebSocketFrame]

Inherited from MidStage[ByteBuffer, WebSocketFrame]

Inherited from Head[WebSocketFrame]

Inherited from Tail[ByteBuffer]

Inherited from Stage

Inherited from FrameTranscoder

Inherited from AnyRef

Inherited from Any

Ungrouped