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

Summary

Callbacks

process_event(event, context, state)

@callback process_event(event :: any(), context :: any(), state :: any()) ::
  {:ok, new_state :: any(), effects :: [any()]} | {:error, reason :: any()}

start_link(opts)

@callback start_link(opts :: keyword()) :: {:ok, pid()} | {:error, term()}