Chiebot-Mirror
/
grpc
mirror of https://github.com/grpc/grpc.git
8
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #14329 from mehrdada/fix-example-unary-stream

Browse Source 
Fix Python example unary/stream conflict
pull/14330/head
Mehrdad Afshari 7 years ago committed by GitHub
parent cd3f579cce 6d13712d07
commit 5d0e9c4aa3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 4
      examples/python/interceptors/headers/generic_client_interceptor.py

4
examples/python/interceptors/headers/generic_client_interceptor.py
Unescape View File

@ -33,14 +33,14 @@ class _GenericClientInterceptor(
request): request):
new_details, new_request_iterator, postprocess = self._fn( new_details, new_request_iterator, postprocess = self._fn(
client_call_details, iter((request,)), False, True) client_call_details, iter((request,)), False, True)
response_it = continuation(new_details, new_request_iterator) response_it = continuation(new_details, next(new_request_iterator))
return postprocess(response_it) if postprocess else response_it return postprocess(response_it) if postprocess else response_it
def intercept_stream_unary(self, continuation, client_call_details, def intercept_stream_unary(self, continuation, client_call_details,
request_iterator): request_iterator):
new_details, new_request_iterator, postprocess = self._fn( new_details, new_request_iterator, postprocess = self._fn(
client_call_details, request_iterator, True, False) client_call_details, request_iterator, True, False)
response = continuation(new_details, next(new_request_iterator)) response = continuation(new_details, new_request_iterator)
return postprocess(response) if postprocess else response return postprocess(response) if postprocess else response
def intercept_stream_stream(self, continuation, client_call_details, def intercept_stream_stream(self, continuation, client_call_details,

Write Preview
Loading…
Cancel
Save