Packages

object EventStreamParser

Flow that converts raw byte string input into ServerSentEvents.

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

Annotations
@ApiMayChange()
Source
EventStreamParser.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventStreamParser
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. 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-akka-http clients, like Play's WSClient.

    maxLineSize

    The maximum size of a line for the event Stream parser

    maxEventSize

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

    emitEmptyEvents

    Should the parser emit events with empty data field

  2. 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-akka-http clients, like Play's WSClient.

    maxLineSize

    The maximum size of a line for the event Stream parser

    maxEventSize

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