Package org.apache.pekko.http.impl.engine.ws

Class FrameEventParser$

java.lang.Object
org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,org.apache.pekko.NotUsed>
org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,T>>
org.apache.pekko.stream.impl.io.ByteStringParser<FrameEvent>
org.apache.pekko.http.impl.engine.ws.FrameEventParser$
All Implemented Interfaces:
org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,FrameEvent>,org.apache.pekko.NotUsed>
public class FrameEventParser$ extends org.apache.pekko.stream.impl.io.ByteStringParser<FrameEvent>
Streaming parser for the WebSocket framing protocol as defined in RFC6455

http://tools.ietf.org/html/rfc6455

0 1 2 3 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 +-+-+-+-+-------+-+-------------+-------------------------------+ |F|R|R|R| opcode|M| Payload len | Extended payload length | |I|S|S|S| (4) |A| (7) | (16/64) | |N|V|V|V| |S| | (if payload len==126/127) | | |1|2|3| |K| | | +-+-+-+-+-------+-+-------------+ - - - - - - - - - - - - - - - + | Extended payload length continued, if payload len == 127 | + - - - - - - - - - - - - - - - +-------------------------------+ | |Masking-key, if MASK set to 1 | +-------------------------------+-------------------------------+ | Masking-key (continued) | Payload Data | +-------------------------------- - - - - - - - - - - - - - - - + : Payload Data continued ... : + - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + | Payload Data continued ... | +---------------------------------------------------------------+

INTERNAL API

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.pekko.stream.impl.io.ByteStringParser

    org.apache.pekko.stream.impl.io.ByteStringParser.ByteReader, org.apache.pekko.stream.impl.io.ByteStringParser.FinishedParser$, org.apache.pekko.stream.impl.io.ByteStringParser.ParseResult<T extends Object>, org.apache.pekko.stream.impl.io.ByteStringParser.ParseResult$, org.apache.pekko.stream.impl.io.ByteStringParser.ParseStep<T extends Object>, org.apache.pekko.stream.impl.io.ByteStringParser.ParsingException, org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic

    Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

    org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M extends Object>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final FrameEventParser$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    FrameEventParser$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pekko.stream.impl.io.ByteStringParser<FrameEvent>.org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic
    createLogic(org.apache.pekko.stream.Attributes attr)
     
    scala.Tuple2<org.apache.pekko.util.ByteString,Object>
    mask(org.apache.pekko.util.ByteString bytes, int mask)
     
    org.apache.pekko.util.ByteString
    mask(org.apache.pekko.util.ByteString bytes, scala.Option<Object> _mask)
     
    scala.Option<scala.Tuple2<Object,String>>
    parseCloseCode(org.apache.pekko.util.ByteString data)
     
    String
    toString()
     

    Methods inherited from class org.apache.pekko.stream.impl.io.ByteStringParser

    CompactionThreshold, initialAttributes, NeedMoreData, org$apache$pekko$stream$impl$io$ByteStringParser$$bytesIn, org$apache$pekko$stream$impl$io$ByteStringParser$$objOut, shape

    Methods inherited from class org.apache.pekko.stream.stage.GraphStage

    createLogicAndMaterializedValue

    Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

    addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, named, traversalBuilder, withAttributes

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Field Details

    • MODULE$

      public static final FrameEventParser$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • FrameEventParser$

      public FrameEventParser$()

  • Method Details

    • createLogic

      public org.apache.pekko.stream.impl.io.ByteStringParser<FrameEvent>.org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic createLogic(org.apache.pekko.stream.Attributes attr)
      Specified by:
      createLogic in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,FrameEvent>>

    • mask

      public org.apache.pekko.util.ByteString mask(org.apache.pekko.util.ByteString bytes, scala.Option<Object> _mask)

    • mask

      public scala.Tuple2<org.apache.pekko.util.ByteString,Object> mask(org.apache.pekko.util.ByteString bytes, int mask)

    • parseCloseCode

      public scala.Option<scala.Tuple2<Object,String>> parseCloseCode(org.apache.pekko.util.ByteString data)

    • toString

      public String toString()
      Overrides:
      toString in class Object