ApolloSignal.Transport.SSEStream (apollo_signal v4.0.0)

Copy Markdown View Source

Lazy enumerable of SSE events and the opening response metadata.

Summary

Types

t(_event_type)

Functions

map(sse_stream, mapper)
metadata(sse_stream)
new(events, metadata)

Types

t(_event_type)

@type t(_event_type) :: %ApolloSignal.Transport.SSEStream{
  events: term(),
  metadata: map()
}

Functions

map(sse_stream, mapper)

@spec map(t(term()), (term() -> term())) :: t(term())

metadata(sse_stream)

@spec metadata(t(term())) :: map()

new(events, metadata)

@spec new(term(), map()) :: t(term())