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


View Source


ack_immediately(message :: t()) :: t()
ack_immediately(messages :: [t(), ...]) :: [t(), ...]

Immediately acknowledges the given message or list of messages.

This function can be used to acknowledge a message (or list of messages) immediately without waiting for the rest of the pipeline.

Acknowledging a message sets that message's acknowledger to a no-op acknowledger so that it's safe to ack at the end of the pipeline.

Returns the updated acked message if a message is passed in, or the updated list of acked messages if a list of messages is passed in.