A GenServer behaviour for real-time media processing pipelines.

Designed for livestreaming, camera effects, and other real-time use cases where frames are processed as they arrive.

Example

defmodule MyLivestream do
  use ExCubecl.MediaPipeline

  def handle_frame(frame, state) do
    frame
    |> ExCubecl.Filter.apply(:beauty_filter, strength: 0.5)
    |> ExCubecl.Video.overlay(state.logo, x: 10, y: 10)
    |> ExCubecl.Transcode.write_frame(state.encoder)
    {:ok, state}
  end
end

Callbacks

• handle_frame/2 — called for each incoming frame. Receives the frame and current state, must return {:ok, new_state} or {:error, reason}.