Update EventStreamUnmarshalling.scala

Author: pjfanning

http/src/main/scala/org/apache/pekko/http/scaladsl/unmarshalling/sse/EventStreamUnmarshalling.scala

@@ -70,18 +70,6 @@ trait EventStreamUnmarshalling {
       settings.oversizedLineStrategy,
       settings.oversizedEventStrategy)
 
-  private final def fromEventsStream(maxLineSize: Int, maxEventSize: Int, emitEmptyEvents: Boolean)
-      : FromEntityUnmarshaller[Source[ServerSentEvent, NotUsed]] =
-    fromEventsStream(maxLineSize, maxEventSize, emitEmptyEvents, "fail-stream")
-
-  private final def fromEventsStream(maxLineSize: Int, maxEventSize: Int, emitEmptyEvents: Boolean,
-      oversizedStrategy: String): FromEntityUnmarshaller[Source[ServerSentEvent, NotUsed]] =
-    fromEventsStreamInternal(maxLineSize, maxEventSize, emitEmptyEvents, oversizedStrategy)
-
-  private final def fromEventsStream(maxLineSize: Int, maxEventSize: Int, emitEmptyEvents: Boolean,
-      oversizedStrategy: OversizedSseStrategy): FromEntityUnmarshaller[Source[ServerSentEvent, NotUsed]] =
-    fromEventsStream(maxLineSize, maxEventSize, emitEmptyEvents, oversizedStrategy, oversizedStrategy)
-
   private final def fromEventsStream(maxLineSize: Int, maxEventSize: Int, emitEmptyEvents: Boolean,
       oversizedLineStrategy: OversizedSseStrategy, oversizedEventStrategy: OversizedSseStrategy)
       : FromEntityUnmarshaller[Source[ServerSentEvent, NotUsed]] = {
@@ -95,16 +83,4 @@ trait EventStreamUnmarshalling {
 
     Unmarshaller.strict(unmarshal).forContentTypes(`text/event-stream`)
   }
-
-  private final def fromEventsStreamInternal(maxLineSize: Int, maxEventSize: Int, emitEmptyEvents: Boolean,
-      oversizedStrategy: String): FromEntityUnmarshaller[Source[ServerSentEvent, NotUsed]] = {
-    val eventStreamParser = EventStreamParser(maxLineSize, maxEventSize, emitEmptyEvents, oversizedStrategy)
-    def unmarshal(entity: HttpEntity) =
-      entity
-        .withoutSizeLimit // Because of streaming: the server keeps the response open and potentially streams huge amounts of data
-        .dataBytes
-        .viaMat(eventStreamParser)(Keep.none)
-
-    Unmarshaller.strict(unmarshal).forContentTypes(`text/event-stream`)
-  }
 }