@@ -105,7 +105,7 @@ def _generate_response(self, response_iterator):
105
105
self ._check_error (e )
106
106
107
107
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
109
109
):
110
110
retries = 0
111
111
@@ -142,12 +142,12 @@ def _retry_call(
142
142
retries += 1
143
143
144
144
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 ,
151
151
):
152
152
new_request_or_iterator = self ._check_message (
153
153
client_call_details , request_or_iterator , is_request_stream
@@ -171,14 +171,14 @@ def intercept_unary_stream(self, continuation, client_call_details, request):
171
171
)
172
172
173
173
def intercept_stream_unary (
174
- self , continuation , client_call_details , request_iterator
174
+ self , continuation , client_call_details , request_iterator
175
175
):
176
176
return self ._intercept_call (
177
177
continuation , client_call_details , request_iterator , True , False
178
178
)
179
179
180
180
def intercept_stream_stream (
181
- self , continuation , client_call_details , request_iterator
181
+ self , continuation , client_call_details , request_iterator
182
182
):
183
183
return self ._intercept_call (
184
184
continuation , client_call_details , request_iterator , True , True
@@ -187,20 +187,20 @@ def intercept_stream_stream(
187
187
188
188
class _GRPCStub (object ):
189
189
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 ,
194
194
):
195
195
self ._desc_pool = desc_pool
196
196
for method_desc in service_desc .methods :
197
197
self ._bind_grpc_method (service_desc , method_desc , channel )
198
198
199
199
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 ,
204
204
):
205
205
method_name = method_desc .name
206
206
method_key = f"/{ service_desc .full_name } /{ method_name } "
0 commit comments