Skip to content

Commit

Permalink
Update broadway.ex
Browse files Browse the repository at this point in the history
  • Loading branch information
josevalim authored Jan 19, 2024
1 parent 78ad896 commit 1897296
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions lib/broadway.ex
Original file line number Diff line number Diff line change
Expand Up @@ -817,9 +817,10 @@ defmodule Broadway do
The length of the list of messages received by this callback is often based
on the `min_demand`/`max_demand` configuration in the processor but ultimately
it depends on the producer and the frequency data arrives. A pipeline that
receives one message per minute will most likely emit single element lists.
Producers which are push-based, rather than pull-based, such as
`BroadwayRabbitMQ.Producer`, are more likely to send messages as they appear.
receives messages rarely will most likely emit lists below the `min_demand`
value. Producers which are push-based, rather than pull-based, such as
`BroadwayRabbitMQ.Producer`, are more likely to send messages as they arrive
(which may skip batching altogether and always be single element lists).
This callback must always return all messages it receives, as
`c:handle_message/3` is still called individually for each message afterwards.
Expand Down

0 comments on commit 1897296

Please sign in to comment.