diff options
Diffstat (limited to 'src/python/grpcio/grpc/_interceptor.py')
-rw-r--r-- | src/python/grpcio/grpc/_interceptor.py | 36 |
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: |