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

update_data(message, fun)

View Source


update_data(message :: t(), fun :: (term() -> term())) :: t()

Updates the data in a message.

This function is usually used inside the Broadway.handle_message/3 implementation to replace data with new processed data.