You're seeing just the function push_messages, go back to Broadway module for more information.
Link to this function

push_messages(broadway, messages)

View Source


push_messages(broadway :: atom(), messages :: [Broadway.Message.t()]) :: :ok

Sends a list of Broadway.Messages 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.