Apache Pekko HTTP
1.1.0
API
Generated with
Apache Pekko HTTP/org.apache.pekko.http/org.apache.pekko.http.scaladsl/org.apache.pekko.http.scaladsl.unmarshalling/org.apache.pekko.http.scaladsl.unmarshalling.sse/EventStreamParser

EventStreamParser

org.apache.pekko.http.scaladsl.unmarshalling.sse.EventStreamParser
@ApiMayChange
object EventStreamParser

Flow that converts raw byte string input into ServerSentEvents.

This API is made for use in non-pekko-http clients, like Play's WSClient.

Attributes

Source
EventStreamParser.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def apply(maxLineSize: Int, maxEventSize: Int): Flow[ByteString, ServerSentEvent, NotUsed]

Flow that converts raw byte string input into ServerSentEvents.

Flow that converts raw byte string input into ServerSentEvents.

This API is made for use in non-pekko-http clients, like Play's WSClient.

Value parameters

maxEventSize

The maximum size of a server-sent event for the event Stream parser

maxLineSize

The maximum size of a line for the event Stream parser

Attributes

Source
EventStreamParser.scala
def apply(maxLineSize: Int, maxEventSize: Int, emitEmptyEvents: Boolean): Flow[ByteString, ServerSentEvent, NotUsed]

Flow that converts raw byte string input into ServerSentEvents.

Flow that converts raw byte string input into ServerSentEvents.

This API is made for use in non-pekko-http clients, like Play's WSClient.

Value parameters

emitEmptyEvents

Should the parser emit events with empty data field

maxEventSize

The maximum size of a server-sent event for the event Stream parser

maxLineSize

The maximum size of a line for the event Stream parser

Attributes

Source
EventStreamParser.scala
Generated with