public class Http2FrameParsing extends org.apache.pekko.stream.impl.io.ByteStringParser<FrameEvent>
Modifier and Type | Class and Description |
---|---|
class |
Http2FrameParsing.Step |
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
Constructor and Description |
---|
Http2FrameParsing(boolean shouldReadPreface,
org.apache.pekko.event.LoggingAdapter log) |
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.stream.stage.GraphStageLogic |
createLogic(org.apache.pekko.stream.Attributes inheritedAttributes) |
static FrameEvent |
parseFrame(Http2Protocol.FrameType tpe,
ByteFlag flags,
int streamId,
org.apache.pekko.stream.impl.io.ByteStringParser.ByteReader payload,
org.apache.pekko.event.LoggingAdapter log) |
static scala.collection.immutable.Seq<FrameEvent.Setting> |
readSettings(org.apache.pekko.stream.impl.io.ByteStringParser.ByteReader payload,
org.apache.pekko.event.LoggingAdapter log) |
CompactionThreshold, initialAttributes, NeedMoreData, org$apache$pekko$stream$impl$io$ByteStringParser$$bytesIn, org$apache$pekko$stream$impl$io$ByteStringParser$$objOut, shape
createLogicAndMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, named, traversalBuilder, withAttributes
public Http2FrameParsing(boolean shouldReadPreface, org.apache.pekko.event.LoggingAdapter log)
public static scala.collection.immutable.Seq<FrameEvent.Setting> readSettings(org.apache.pekko.stream.impl.io.ByteStringParser.ByteReader payload, org.apache.pekko.event.LoggingAdapter log)
public static FrameEvent parseFrame(Http2Protocol.FrameType tpe, ByteFlag flags, int streamId, org.apache.pekko.stream.impl.io.ByteStringParser.ByteReader payload, org.apache.pekko.event.LoggingAdapter log)
public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes inheritedAttributes)
createLogic
in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,FrameEvent>>