@@ -105,7 +105,7 @@ def _generate_response(self, response_iterator):
105105 self ._check_error (e )
106106
107107 def _retry_call (
108- self , continuation , client_call_details , request_or_iterator , is_stream
108+ self , continuation , client_call_details , request_or_iterator , is_stream
109109 ):
110110 retries = 0
111111
@@ -142,12 +142,12 @@ def _retry_call(
142142 retries += 1
143143
144144 def _intercept_call (
145- self ,
146- continuation ,
147- client_call_details ,
148- request_or_iterator ,
149- is_request_stream ,
150- is_response_stream ,
145+ self ,
146+ continuation ,
147+ client_call_details ,
148+ request_or_iterator ,
149+ is_request_stream ,
150+ is_response_stream ,
151151 ):
152152 new_request_or_iterator = self ._check_message (
153153 client_call_details , request_or_iterator , is_request_stream
@@ -171,14 +171,14 @@ def intercept_unary_stream(self, continuation, client_call_details, request):
171171 )
172172
173173 def intercept_stream_unary (
174- self , continuation , client_call_details , request_iterator
174+ self , continuation , client_call_details , request_iterator
175175 ):
176176 return self ._intercept_call (
177177 continuation , client_call_details , request_iterator , True , False
178178 )
179179
180180 def intercept_stream_stream (
181- self , continuation , client_call_details , request_iterator
181+ self , continuation , client_call_details , request_iterator
182182 ):
183183 return self ._intercept_call (
184184 continuation , client_call_details , request_iterator , True , True
@@ -187,20 +187,20 @@ def intercept_stream_stream(
187187
188188class _GRPCStub (object ):
189189 def __init__ (
190- self ,
191- desc_pool : DescriptorPool ,
192- service_desc : ServiceDescriptor ,
193- channel : grpc .Channel ,
190+ self ,
191+ desc_pool : DescriptorPool ,
192+ service_desc : ServiceDescriptor ,
193+ channel : grpc .Channel ,
194194 ):
195195 self ._desc_pool = desc_pool
196196 for method_desc in service_desc .methods :
197197 self ._bind_grpc_method (service_desc , method_desc , channel )
198198
199199 def _bind_grpc_method (
200- self ,
201- service_desc : ServiceDescriptor ,
202- method_desc : MethodDescriptor ,
203- channel : grpc .Channel ,
200+ self ,
201+ service_desc : ServiceDescriptor ,
202+ method_desc : MethodDescriptor ,
203+ channel : grpc .Channel ,
204204 ):
205205 method_name = method_desc .name
206206 method_key = f"/{ service_desc .full_name } /{ method_name } "
0 commit comments