Class EventStreamParser

java.lang.Object
akka.http.scaladsl.unmarshalling.sse.EventStreamParser

public class EventStreamParser extends 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.

  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    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 Details

    • EventStreamParser

      public EventStreamParser()
  • Method Details

    • 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)