Method patch_broker

tests/brokers/base/basic.py:21–39

(
        self,
        *brokers: BrokerUsecase,
        **kwargs: Any,
    )

        raise NotImplementedError

    def patch_broker(
        self,
        *brokers: BrokerUsecase,
        **kwargs: Any,
    ) -> BrokerUsecase | list[BrokerUsecase]:
        if len(brokers) == 1:
            return brokers[0]

        @asynccontextmanager
        async def enter_broker() -> AsyncIterator[list[BrokerUsecase]]:
            started_brokers = []

            async with AsyncExitStack() as stack:
                for br in brokers:
                    started_brokers.append(await stack.enter_async_context(br))  # noqa: PERF401

                yield started_brokers

        return enter_broker()

    def get_subscriber_params(
        self,