ArchAstro.SSE.Stream (archastro v0.2.0)

Copy Markdown

Typed, lazy stream of decoded server-sent events.

Summary

Types

t(event)

Functions

new(source, decoder)

Types

t(event)

@type t(event) :: %ArchAstro.SSE.Stream{
  decoder: (ArchAstro.SSE.Event.t() -> event),
  source: Enumerable.t()
}

Functions

new(source, decoder)

@spec new(Enumerable.t(), (ArchAstro.SSE.Event.t() -> event)) :: t(event)
when event: var