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