SourceType faststream.broker.message.SourceType # Bases: str, Enum Consume class-attribute instance-attribute # Consume = 'Consume' Message consumed by basic subscriber flow. Response class-attribute instance-attribute # Response = 'Response' RPC response consumed.