aboutsummaryrefslogtreecommitdiff
path: root/src/python/grpcio/grpc/_interceptor.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/python/grpcio/grpc/_interceptor.py')
-rw-r--r--src/python/grpcio/grpc/_interceptor.py36
1 files changed, 4 insertions, 32 deletions
diff --git a/src/python/grpcio/grpc/_interceptor.py b/src/python/grpcio/grpc/_interceptor.py
index 94abafebaa..36bce4e3ba 100644
--- a/src/python/grpcio/grpc/_interceptor.py
+++ b/src/python/grpcio/grpc/_interceptor.py
@@ -684,85 +684,57 @@ class _Channel(grpc.Channel):
def unsubscribe(self, callback: Callable):
self._channel.unsubscribe(callback)
- # pylint: disable=arguments-differ
def unary_unary(
self,
method: str,
request_serializer: Optional[SerializingFunction] = None,
response_deserializer: Optional[DeserializingFunction] = None,
- _registered_method: Optional[bool] = False,
) -> grpc.UnaryUnaryMultiCallable:
- # pytype: disable=wrong-arg-count
thunk = lambda m: self._channel.unary_unary(
- m,
- request_serializer,
- response_deserializer,
- _registered_method,
+ m, request_serializer, response_deserializer
)
- # pytype: enable=wrong-arg-count
if isinstance(self._interceptor, grpc.UnaryUnaryClientInterceptor):
return _UnaryUnaryMultiCallable(thunk, method, self._interceptor)
else:
return thunk(method)
- # pylint: disable=arguments-differ
def unary_stream(
self,
method: str,
request_serializer: Optional[SerializingFunction] = None,
response_deserializer: Optional[DeserializingFunction] = None,
- _registered_method: Optional[bool] = False,
) -> grpc.UnaryStreamMultiCallable:
- # pytype: disable=wrong-arg-count
thunk = lambda m: self._channel.unary_stream(
- m,
- request_serializer,
- response_deserializer,
- _registered_method,
+ m, request_serializer, response_deserializer
)
- # pytype: enable=wrong-arg-count
if isinstance(self._interceptor, grpc.UnaryStreamClientInterceptor):
return _UnaryStreamMultiCallable(thunk, method, self._interceptor)
else:
return thunk(method)
- # pylint: disable=arguments-differ
def stream_unary(
self,
method: str,
request_serializer: Optional[SerializingFunction] = None,
response_deserializer: Optional[DeserializingFunction] = None,
- _registered_method: Optional[bool] = False,
) -> grpc.StreamUnaryMultiCallable:
- # pytype: disable=wrong-arg-count
thunk = lambda m: self._channel.stream_unary(
- m,
- request_serializer,
- response_deserializer,
- _registered_method,
+ m, request_serializer, response_deserializer
)
- # pytype: enable=wrong-arg-count
if isinstance(self._interceptor, grpc.StreamUnaryClientInterceptor):
return _StreamUnaryMultiCallable(thunk, method, self._interceptor)
else:
return thunk(method)
- # pylint: disable=arguments-differ
def stream_stream(
self,
method: str,
request_serializer: Optional[SerializingFunction] = None,
response_deserializer: Optional[DeserializingFunction] = None,
- _registered_method: Optional[bool] = False,
) -> grpc.StreamStreamMultiCallable:
- # pytype: disable=wrong-arg-count
thunk = lambda m: self._channel.stream_stream(
- m,
- request_serializer,
- response_deserializer,
- _registered_method,
+ m, request_serializer, response_deserializer
)
- # pytype: enable=wrong-arg-count
if isinstance(self._interceptor, grpc.StreamStreamClientInterceptor):
return _StreamStreamMultiCallable(thunk, method, self._interceptor)
else: