Searched refs:request_consumer (Results 1 – 1 of 1) sorted by relevance
158 def _run_request_pipe_thread(request_iterator, request_consumer, argument166 request_consumer.consume(request)169 request_consumer.terminate()213 request_consumer = stream_unary_event(216 _run_request_pipe_thread(request_iterator, request_consumer,229 request_consumer = stream_stream_event(231 _run_request_pipe_thread(request_iterator, request_consumer,