Class EventStreamParser
- java.lang.Object
-
- akka.http.scaladsl.unmarshalling.sse.EventStreamParser
-
public class EventStreamParser extends java.lang.Object
Flow that converts raw byte string input intoServerSentEvent
s.This API is made for use in non-akka-http clients, like Play's WSClient.
-
-
Constructor Summary
Constructors Constructor Description EventStreamParser()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static akka.stream.scaladsl.Flow<akka.util.ByteString,ServerSentEvent,akka.NotUsed>
apply(int maxLineSize, int maxEventSize)
Flow that converts raw byte string input intoServerSentEvent
s.static akka.stream.scaladsl.Flow<akka.util.ByteString,ServerSentEvent,akka.NotUsed>
apply(int maxLineSize, int maxEventSize, boolean emitEmptyEvents)
Flow that converts raw byte string input intoServerSentEvent
s.
-
-
-
Method Detail
-
apply
public static akka.stream.scaladsl.Flow<akka.util.ByteString,ServerSentEvent,akka.NotUsed> apply(int maxLineSize, int maxEventSize)
Flow that converts raw byte string input intoServerSentEvent
s.This API is made for use in non-akka-http clients, like Play's WSClient.
- Parameters:
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- Returns:
- (undocumented)
-
apply
public static akka.stream.scaladsl.Flow<akka.util.ByteString,ServerSentEvent,akka.NotUsed> apply(int maxLineSize, int maxEventSize, boolean emitEmptyEvents)
Flow that converts raw byte string input intoServerSentEvent
s.This API is made for use in non-akka-http clients, like Play's WSClient.
- Parameters:
maxLineSize
- The maximum size of a line for the event Stream parsermaxEventSize
- The maximum size of a server-sent event for the event Stream parseremitEmptyEvents
- Should the parser emit events with empty data field- Returns:
- (undocumented)
-
-