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

Class FrameEventParser

java.lang.Object
org.apache.pekko.http.impl.engine.ws.FrameEventParser
public class FrameEventParser extends Object
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

  • Constructor Summary

    Constructors
    Constructor
    Description
    FrameEventParser()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.pekko.stream.Graph<S,M>
    addAttributes(org.apache.pekko.stream.Attributes attr)
     
    static org.apache.pekko.stream.Graph<S,M>
    async()
     
    static org.apache.pekko.stream.Graph<S,M>
    async(String dispatcher)
     
    static org.apache.pekko.stream.Graph<S,M>
    async(String dispatcher, int inputBufferSize)
     
    static org.apache.pekko.stream.impl.io.ByteStringParser<FrameEvent>.org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic
    createLogic(org.apache.pekko.stream.Attributes attr)
     
    static final scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,org.apache.pekko.NotUsed>
    createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes)
     
    static scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,M>
    createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes, org.apache.pekko.stream.Materializer materializer)
     
    static org.apache.pekko.stream.Attributes
    getAttributes()
     
    static org.apache.pekko.stream.Attributes
    initialAttributes()
     
    static scala.Tuple2<org.apache.pekko.util.ByteString,Object>
    mask(org.apache.pekko.util.ByteString bytes, int mask)
     
    static org.apache.pekko.util.ByteString
    mask(org.apache.pekko.util.ByteString bytes, scala.Option<Object> _mask)
     
    static org.apache.pekko.stream.Graph<S,M>
    named(String name)
     
    static scala.Option<scala.Tuple2<Object,String>>
    parseCloseCode(org.apache.pekko.util.ByteString data)
     
    static final org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,T>
    shape()
     
    static String
    toString()
     
    static final org.apache.pekko.stream.impl.TraversalBuilder
    traversalBuilder()
     
    static final org.apache.pekko.stream.Graph<S,M>
    withAttributes(org.apache.pekko.stream.Attributes attr)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • FrameEventParser

      public FrameEventParser()

  • Method Details

    • createLogic

      public static org.apache.pekko.stream.impl.io.ByteStringParser<FrameEvent>.org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic createLogic(org.apache.pekko.stream.Attributes attr)

    • mask

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

    • mask

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

    • parseCloseCode

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

    • toString

      public static String toString()

    • named

      public static org.apache.pekko.stream.Graph<S,M> named(String name)

    • async

      public static org.apache.pekko.stream.Graph<S,M> async()

    • async

      public static org.apache.pekko.stream.Graph<S,M> async(String dispatcher)

    • async

      public static org.apache.pekko.stream.Graph<S,M> async(String dispatcher, int inputBufferSize)

    • addAttributes

      public static org.apache.pekko.stream.Graph<S,M> addAttributes(org.apache.pekko.stream.Attributes attr)

    • getAttributes

      public static org.apache.pekko.stream.Attributes getAttributes()

    • createLogicAndMaterializedValue

      public static scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,M> createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes, org.apache.pekko.stream.Materializer materializer)

    • traversalBuilder

      public static final org.apache.pekko.stream.impl.TraversalBuilder traversalBuilder()

    • withAttributes

      public static final org.apache.pekko.stream.Graph<S,M> withAttributes(org.apache.pekko.stream.Attributes attr)

    • createLogicAndMaterializedValue

      public static final scala.Tuple2<org.apache.pekko.stream.stage.GraphStageLogic,org.apache.pekko.NotUsed> createLogicAndMaterializedValue(org.apache.pekko.stream.Attributes inheritedAttributes)

    • initialAttributes

      public static org.apache.pekko.stream.Attributes initialAttributes()

    • shape

      public static final org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,T> shape()