org.apache.pekko.http.scaladsl.unmarshalling.sse

Class ServerSentEventParser

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,org.apache.pekko.NotUsed>

org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<java.lang.String,ServerSentEvent>>

org.apache.pekko.http.scaladsl.unmarshalling.sse.ServerSentEventParser

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<java.lang.String,ServerSentEvent>,org.apache.pekko.NotUsed>

public final class ServerSentEventParser
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<java.lang.String,ServerSentEvent>>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ServerSentEventParser.Builder
static class	ServerSentEventParser.PosInt$

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M>

Constructor Summary

Constructors

Constructor and Description
ServerSentEventParser(int maxEventSize, boolean emitEmptyEvents)

Method Summary

Modifier and Type	Method and Description
org.apache.pekko.stream.stage.GraphStageLogic	createLogic(org.apache.pekko.stream.Attributes attributes)
org.apache.pekko.stream.FlowShape<java.lang.String,ServerSentEvent>	shape()

Methods inherited from class org.apache.pekko.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class org.apache.pekko.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

Methods inherited from interface org.apache.pekko.stream.Graph

$init$, GraphMapMatVal, mapMaterializedValue

Constructor Detail

ServerSentEventParser

public ServerSentEventParser(int maxEventSize,
                             boolean emitEmptyEvents)

Method Detail

shape

public org.apache.pekko.stream.FlowShape<java.lang.String,ServerSentEvent> shape()

createLogic

public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes attributes)

Specified by:

createLogic in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<java.lang.String,ServerSentEvent>>