Package akka.http.scaladsl.unmarshalling.sse

Class LineParser

java.lang.Object
akka.stream.stage.GraphStageWithMaterializedValue<S,akka.NotUsed>
akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,String>>
akka.http.scaladsl.unmarshalling.sse.LineParser
All Implemented Interfaces:
akka.stream.Graph<akka.stream.FlowShape<akka.util.ByteString,String>,akka.NotUsed>
public final class LineParser extends akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,String>>
INTERNAL API

  • Nested Class Summary

    Nested classes/interfaces inherited from interface akka.stream.Graph

    akka.stream.Graph.GraphMapMatVal<S extends akka.stream.Shape,M extends Object>

  • Constructor Summary

    Constructors
    Constructor
    Description
    LineParser(int maxLineSize)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static byte
    CR()
     
    akka.stream.stage.GraphStageLogic
    createLogic(akka.stream.Attributes attributes)
     
    static byte
    LF()
     
    akka.stream.FlowShape<akka.util.ByteString,String>
    shape()
     

    Methods inherited from class akka.stream.stage.GraphStage

    createLogicAndMaterializedValue

    Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

    addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • LineParser

      public LineParser(int maxLineSize)

  • Method Details

    • CR

      public static byte CR()

    • LF

      public static byte LF()

    • shape

      public akka.stream.FlowShape<akka.util.ByteString,String> shape()

    • createLogic

      public akka.stream.stage.GraphStageLogic createLogic(akka.stream.Attributes attributes)
      Specified by:
      createLogic in class akka.stream.stage.GraphStage<akka.stream.FlowShape<akka.util.ByteString,String>>