File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed
Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -34,10 +34,9 @@ class _AsyncRequestQueueGenerator:
3434 otherwise open-ended set of requests to send through a request-streaming
3535 (or bidirectional) RPC.
3636
37- The reason this is necessary
38-
39- is because it's let's user have control on the when they would want to
40- send requests proto messages instead of sending all of them initilally.
37+ The reason this is necessary is because it lets the user have control on
38+ when they would want to send requests proto messages instead of sending all
39+ of them initilally.
4140
4241 This is achieved via asynchronous queue (asyncio.Queue),
4342 gRPC awaits until there's a message in the queue.
@@ -220,7 +219,7 @@ async def recv(self):
220219 protobuf.Message: The received message.
221220 """
222221 if self .call is None :
223- raise ValueError ("Can not recv() on an RPC that has never been open()ed ." )
222+ raise ValueError ("Can not recv() on an RPC that has never been opened ." )
224223
225224 return await self .call .read ()
226225
You can’t perform that action at this time.
0 commit comments