Current section
Files
Jump to
Current section
Files
lib/strom.ex
defmodule Strom do
@moduledoc "Strom is a framework for building stream processing applications."
@type event() :: any()
@type stream_name() :: any()
@type component() :: struct()
@type stream() :: Enumerable.t(event())
@type flow() :: %{optional(stream_name()) => stream()}
end