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

Class FrameEventParser

java.lang.Object

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

public class FrameEventParser
extends java.lang.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 and Description
FrameEventParser()

Method Summary

Modifier and Type	Method and 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(java.lang.String dispatcher)
static org.apache.pekko.stream.Graph<S,M>	async(java.lang.String dispatcher, int inputBufferSize)
static org.apache.pekko.stream.impl.io.ByteStringParser.ParsingLogic	createLogic(org.apache.pekko.stream.Attributes attr)
static 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,java.lang.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<java.lang.Object> _mask)
static org.apache.pekko.stream.Graph<S,M>	named(java.lang.String name)
static scala.Option<scala.Tuple2<java.lang.Object,java.lang.String>>	parseCloseCode(org.apache.pekko.util.ByteString data)
static org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,T>	shape()
static java.lang.String	toString()
static org.apache.pekko.stream.impl.TraversalBuilder	traversalBuilder()
static 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 Detail

FrameEventParser

public FrameEventParser()

Method Detail

createLogic

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

mask

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

parseCloseCode

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

toString

public static java.lang.String toString()

named

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

async

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

async

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

async

public static org.apache.pekko.stream.Graph<S,M> async(java.lang.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()