Quantum

v2.1.2

Quantum v2.1.2 Quantum.ExecutionBroadcaster View Source

Receives Added / Removed Jobs, Broadcasts Executions of Jobs

Link to this section Summary

Functions

handle_events(events, _, state)

Invoked on :producer_consumer and :consumer stages to handle events

start_link(name, job_broadcaster)

Start Stage

Link to this section Functions

Link to this function handle_events(events, _, state) View Source

Invoked on :producer_consumer and :consumer stages to handle events.

Must always be explicitly implemented by such types.

Return values are the same as c:handle_cast/2.

Callback implementation for GenStage.handle_events/3.

Link to this function start_link(name, job_broadcaster) View Source 
start_link(GenServer.server, GenServer.server) :: GenServer.on_start

Start Stage

Arguments

  • name - The name of the stage
  • job_broadcaster - The name of the stage to listen to