MCPcopy
hub / github.com/ag2ai/faststream / get_subscriber_params

Method get_subscriber_params

tests/brokers/base/basic.py:41–49  ·  view source on GitHub ↗
(
        self,
        *args: Any,
        **kwargs: Any,
    )

Source from the content-addressed store, hash-verified

39 return enter_broker()
40
41 def get_subscriber_params(
42 self,
43 *args: Any,
44 **kwargs: Any,
45 ) -> tuple[
46 tuple[Any, ...],
47 dict[str, Any],
48 ]:
49 return args, kwargs
50
51 @abstractmethod
52 def get_router(self, **kwargs: Any) -> BrokerRouter:

Calls

no outgoing calls