PacketFlow.Stream.Window behaviour (packetflow v0.1.0)

Summary

Callbacks

add_to_window(window, event)

@callback add_to_window(window :: map(), event :: any()) :: {:ok, updated_window :: map()}

create_window(window_type, size)

@callback create_window(window_type :: atom(), size :: integer()) ::
  {:ok, window :: map()} | {:error, reason :: any()}

process_window(window)

@callback process_window(window :: map()) :: {:ok, result :: any()}