PacketFlow.Stream.Window behaviour
(packetflow v0.1.0)
Callbacks
@callback add_to_window(window :: map(), event :: any()) :: {:ok, updated_window :: map()}
@callback create_window(window_type :: atom(), size :: integer()) ::
{:ok, window :: map()} | {:error, reason :: any()}
@callback process_window(window :: map()) :: {:ok, result :: any()}