Skip to content

default_filter

faststream.broker.utils.default_filter async #

default_filter(msg)

A function to filter stream messages.

Source code in faststream/broker/utils.py 
65
66
67
async def default_filter(msg: "StreamMessage[Any]") -> bool:
    """A function to filter stream messages."""
    return not msg.processed