public class EventStreamParser
extends java.lang.Object
ServerSentEvent
s.
This API is made for use in non-akka-http clients, like Play's WSClient.
Constructor and Description |
---|
EventStreamParser() |
Modifier and Type | Method and Description |
---|---|
static akka.stream.scaladsl.Flow<akka.util.ByteString,ServerSentEvent,akka.NotUsed> |
apply(int maxLineSize,
int maxEventSize)
Flow that converts raw byte string input into
ServerSentEvent s. |
public static akka.stream.scaladsl.Flow<akka.util.ByteString,ServerSentEvent,akka.NotUsed> apply(int maxLineSize, int maxEventSize)
ServerSentEvent
s.
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 parsermaxEventSize
- The maximum size of a server-sent event for the event Stream parser