Broadway.push_messages
You're seeing just the function
push_messages
, go back to Broadway module for more information.
Specs
push_messages(broadway :: atom(), messages :: [Broadway.Message.t()]) :: :ok
Sends a list of Broadway.Message
s to the Broadway pipeline.
The producer is randomly chosen among all sets of producers/stages. This is used to send out of band data to a Broadway pipeline.