Class EventStreamUnmarshalling
- java.lang.Object
-
- akka.http.javadsl.unmarshalling.sse.EventStreamUnmarshalling
-
public class EventStreamUnmarshalling extends java.lang.ObjectUsingfromEventsStreamlets aHttpEntitywith atext/event-streammedia type be unmarshalled to a source ofServerSentEvents.
-
-
Constructor Summary
Constructors Constructor Description EventStreamUnmarshalling()
-
Method Summary
All Methods Static Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static Unmarshaller<HttpEntity,akka.stream.javadsl.Source<ServerSentEvent,akka.NotUsed>>fromEventsStream(akka.actor.ActorSystem system)Lets anHttpEntitywith atext/event-streammedia type be unmarshalled to a source ofServerSentEvents.static Unmarshaller<HttpEntity,akka.stream.javadsl.Source<ServerSentEvent,akka.NotUsed>>fromEventsStream(ServerSentEventSettings settings)Lets anHttpEntitywith atext/event-streammedia type be unmarshalled to a source ofServerSentEvents.static Unmarshaller<HttpEntity,akka.stream.javadsl.Source<ServerSentEvent,akka.NotUsed>>fromEventStream()Deprecated.Binary compatibility method.
-
-
-
Method Detail
-
fromEventsStream
public static Unmarshaller<HttpEntity,akka.stream.javadsl.Source<ServerSentEvent,akka.NotUsed>> fromEventsStream(akka.actor.ActorSystem system)
Lets anHttpEntitywith atext/event-streammedia type be unmarshalled to a source ofServerSentEvents.- Parameters:
system- (undocumented)- Returns:
- (undocumented)
-
fromEventsStream
public static Unmarshaller<HttpEntity,akka.stream.javadsl.Source<ServerSentEvent,akka.NotUsed>> fromEventsStream(ServerSentEventSettings settings)
Lets anHttpEntitywith atext/event-streammedia type be unmarshalled to a source ofServerSentEvents.- Parameters:
settings- overrides the default unmarshalling behavior.- Returns:
- (undocumented)
-
fromEventStream
public static Unmarshaller<HttpEntity,akka.stream.javadsl.Source<ServerSentEvent,akka.NotUsed>> fromEventStream()
Deprecated.Binary compatibility method. Invocations should have an implicit ActorSystem in scope to provide access to configuration. Since 10.1.8.
-
-