Class EventStreamParser


  • public class EventStreamParser
    extends java.lang.Object
    Flow that converts raw byte string input into ServerSentEvents.

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

    • 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 into ServerSentEvents.
      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 into ServerSentEvents.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • EventStreamParser

        public EventStreamParser()
    • 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 into ServerSentEvents.

        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 parser
        maxEventSize - 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 into ServerSentEvents.

        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 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
        Returns:
        (undocumented)