Apply feedback review

pull/23092/head
Pau Freixes 5 years ago
parent f9d9793c96
commit c8b7f22474
  1. 2
      src/python/grpcio/grpc/experimental/aio/_interceptor.py
  2. 4
      src/python/grpcio_tests/tests_aio/unit/client_stream_stream_interceptor_test.py

@ -962,7 +962,7 @@ class UnaryStreamCallResponseIterator(_StreamCallResponseIterator,
class StreamStreamCallResponseIterator(_StreamCallResponseIterator, class StreamStreamCallResponseIterator(_StreamCallResponseIterator,
_base_call.StreamStreamCall): _base_call.StreamStreamCall):
"""UnaryStreamCall class wich uses an alternative response iterator.""" """StreamStreamCall class wich uses an alternative response iterator."""
async def read(self) -> ResponseType: async def read(self) -> ResponseType:
# Behind the scenes everyting goes through the # Behind the scenes everyting goes through the

@ -91,8 +91,8 @@ class TestStreamStreamClientInterceptor(AioTestBase):
response_cnt = 0 response_cnt = 0
async for response in call: async for response in call:
response_cnt += 1 response_cnt += 1
self.assertIs(type(response), self.assertIsInstance(
messages_pb2.StreamingOutputCallResponse) response, messages_pb2.StreamingOutputCallResponse)
self.assertEqual(_RESPONSE_PAYLOAD_SIZE, self.assertEqual(_RESPONSE_PAYLOAD_SIZE,
len(response.payload.body)) len(response.payload.body))

Loading…
Cancel
Save