We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6fabb1f commit 2df8cc4Copy full SHA for 2df8cc4
google/api_core/bidi_async.py
@@ -153,7 +153,7 @@ def _create_queue(self):
153
async def open(self):
154
"""Opens the stream."""
155
if self.is_active:
156
- raise ValueError("Can not open an already open stream.")
+ raise ValueError("Cannot open an already open stream.")
157
158
request_generator = _AsyncRequestQueueGenerator(
159
self._request_queue, initial_request=self._initial_request
@@ -168,8 +168,6 @@ async def open(self):
168
169
request_generator.call = call
170
171
- # TODO: api_core should expose the future interface for wrapped
172
- # callables as well.
173
if hasattr(call, "_wrapped"): # pragma: NO COVER
174
call._wrapped.add_done_callback(self._on_call_done)
175
else:
0 commit comments