Fix missing iter on request stream (googleapis#5078)

Jon Wayne Parrott · web-flow · commit 1374b464ab2a · 2018-03-20T13:37:12.000-07:00
diff --git a/pubsub/google/cloud/pubsub_v1/subscriber/_consumer.py b/pubsub/google/cloud/pubsub_v1/subscriber/_consumer.py
@@ -320,7 +320,7 @@ def _blocking_consume(self, policy):
             initial_request = policy.get_initial_request()
             request_generator = _RequestQueueGenerator(
                 self._request_queue, initial_request=initial_request)
-            rpc = policy.call_rpc(request_generator)
+            rpc = policy.call_rpc(iter(request_generator))
             request_generator.rpc = rpc
             responses = _pausable_iterator(rpc, self._can_consume)
             try:
