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>, org.apache.pekko.stream.impl.io.ByteStringParser.ParseResult$, org.apache.pekko.stream.impl.io.ByteStringParser.ParseStep<T>, 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>

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
FrameEventParser$()

Method Summary

Modifier and Type	Method and Description
org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic	createLogic(org.apache.pekko.stream.Attributes attr)
scala.Tuple2<org.apache.pekko.util.ByteString,java.lang.Object>	mask(org.apache.pekko.util.ByteString bytes, int mask)
org.apache.pekko.util.ByteString	mask(org.apache.pekko.util.ByteString bytes, scala.Option<java.lang.Object> _mask)
scala.Option<scala.Tuple2<java.lang.Object,java.lang.String>>	parseCloseCode(org.apache.pekko.util.ByteString data)
java.lang.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

Methods inherited from interface org.apache.pekko.stream.Graph

$init$, GraphMapMatVal, mapMaterializedValue

Field Detail

MODULE$

public static final FrameEventParser$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

FrameEventParser$

public FrameEventParser$()

Method Detail

createLogic

public 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<java.lang.Object> _mask)

mask

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

parseCloseCode

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object