How to write a locust test to test bidirectional flow? Why are the requests not leaving?

Question

Python

Why are the requests not leaving? Doesn't write anything to the console at all.

grpc_gevent.init_gevent()


class GrpcClient:
    def __init__(self, stub):
        self._stub_class = stub.__class__
        self._stub = stub

    def __getattr__(self, name):
        func = self._stub_class.__getattribute__(self._stub, name)

        def wrapper(*args, **kwargs):
            request_meta = {
                "request_type": "grpc",
                "name": name,
                "start_time": time.time(),
                "response_length": 0,
                "exception": None,
                "context": None,
                "response": None,
            }
            request_meta["responses"] = func(*args, **kwargs)
            print(request_meta["responses"]) # ничего не выводит
            for response in request_meta["responses"]:
                try:
                    start_perf_counter = time.perf_counter()

                    print(response)
                    request_meta["response_length"] = len(MessageToJson(response)) # каждый ответ
                    # len(list(iter(request_meta["response"])))
                except grpc.RpcError as e:
                    request_meta["exception"] = e
                request_meta["response_time"] = (
                    time.perf_counter() - start_perf_counter) * 1000
                events.request.fire(**request_meta)
                yield request_meta["response"]
        return wrapper


class GrpcUser(User):
    abstract = True

    stub_class = None

    def __init__(self, environment):
        super().__init__(environment)

        self._channel = grpc.insecure_channel(ADDRESS)
        self._channel_closed = False
        stub = self.stub_class(self._channel)
        self.client = GrpcClient(stub)

    def stop(self, force=False):
        self._channel_closed = True
        time.sleep(1)
        self._channel.close()
        super().stop(force=True)


class HelloGrpcUser(GrpcUser):
    host = ADDRESS
    stub_class = stt_pb2_grpc.SpeechToTextServiceStub

    @task
    def streamingRecognize(self):
        if not self._channel_closed:
            self.client.StreamingRecognize(generate_requests(
                "test.wav"
            ))
        time.sleep(1)