Skip to content

KafkaRoute

faststream.broker.router.BrokerRoute #

BrokerRoute(call: Callable[..., T_HandlerReturn], *args: Any, **kwargs: Any)

Bases: Generic[MsgType, T_HandlerReturn]

A generic class to represent a broker route.

PARAMETER DESCRIPTION
call

callable object representing the route
*args

variable length arguments for the route

DEFAULT: ()

**kwargs

variable length keyword arguments for the route

DEFAULT: {}

Initialize a callable object with arguments and keyword arguments.

PARAMETER DESCRIPTION
call

A callable object.

TYPE: Callable[..., T_HandlerReturn]

*args

Positional arguments to be passed to the callable object.

TYPE: Any DEFAULT: ()

**kwargs

Keyword arguments to be passed to the callable object.

TYPE: Any DEFAULT: {}

Source code in faststream/broker/router.py 
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
def __init__(
    self,
    call: Callable[..., T_HandlerReturn],
    *args: Any,
    **kwargs: Any,
) -> None:
    """Initialize a callable object with arguments and keyword arguments.

    Args:
        call: A callable object.
        *args: Positional arguments to be passed to the callable object.
        **kwargs: Keyword arguments to be passed to the callable object.

    """
    self.call = call
    self.args = args
    self.kwargs = kwargs

args instance-attribute #

args: Tuple[Any, ...] = args

call instance-attribute #

call: Callable[..., T_HandlerReturn] = call

kwargs instance-attribute #

kwargs: AnyDict = kwargs