public final class LineParser
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,java.lang.String>>
Constructor and Description |
---|
LineParser(int maxLineSize) |
Modifier and Type | Method and Description |
---|---|
static byte |
CR() |
org.apache.pekko.stream.stage.GraphStageLogic |
createLogic(org.apache.pekko.stream.Attributes attributes) |
static byte |
LF() |
org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,java.lang.String> |
shape() |
createLogicAndMaterializedValue
addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes
public static byte CR()
public static byte LF()
public org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,java.lang.String> shape()
public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes attributes)
createLogic
in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<org.apache.pekko.util.ByteString,java.lang.String>>