Home
last modified time | relevance | path

Searched refs:_call (Results 1 – 25 of 32) sorted by relevance

12

/third_party/grpc/src/objective-c/ProtoRPC/
DProtoRPC.m77 GRPCStreamingProtoCall *_call;
92 _call = [[GRPCStreamingProtoCall alloc] initWithRequestOptions:requestOptions
102 [_call start];
103 [_call receiveNextMessage];
104 [_call writeMessage:_message];
105 [_call finish];
109 [_call cancel];
124 GRPCCall2 *_call;
164 _call = [[GRPCCall2 alloc] initWithRequestOptions:_requestOptions
174 copiedCall = _call;
[all …]
/third_party/grpc/src/objective-c/GRPCClient/private/GRPCCore/
DGRPCCallInternal.m39 GRPCCall *_call;
115 _call = [[GRPCCall alloc] initWithHost:_requestOptions.host
127 [_call setResponseDispatchQueue:_dispatchQueue];
129 [_call.requestHeaders addEntriesFromDictionary:_callOptions.initialMetadata];
132 [_call receiveNextMessages:_pendingReceiveNextMessages];
135 copiedCall = _call;
143 [self issueInitialMetadata:self->_call.responseHeaders];
156 [self issueInitialMetadata:self->_call.responseHeaders];
158 [self issueCloseWithTrailingMetadata:self->_call.responseTrailers error:errorOrNil];
160 // Clearing _call must happen *after* dispatching close in order to get trailing
[all …]
DGRPCWrappedCall.m241 grpc_call *_call;
253 _call = unmanagedCall;
271 if (_call != NULL) {
279 grpc_call_start_batch(_call, ops_array, nops, (__bridge_retained void *)(^(bool success) {
305 if (_call != NULL) {
306 grpc_call_cancel(_call, NULL);
313 if (_call != NULL) {
318 grpc_call_unref(_call);
319 _call = NULL;
326 if (_call != NULL) {
[all …]
DGRPCRequestHeaders.m57 __weak GRPCCall *_call;
84 _call = call;
97 if (_call.state != GRXWriterStateNotStarted) {
/third_party/python/Lib/tkinter/
Dfont.py98 self._call = tk.call
121 self._call("font", "delete", self.name)
136 return self._call("font", "actual", self.name, *args)
139 self._split(self._call("font", "actual", self.name, *args)))
143 return self._call("font", "config", self.name, "-"+option)
148 self._call("font", "config", self.name,
152 self._split(self._call("font", "config", self.name)))
161 return self._tk.getint(self._call("font", "measure", self.name, *args))
175 self._call("font", "metrics", self.name, *args))
177 res = self._split(self._call("font", "metrics", self.name, *args))
/third_party/grpc/src/objective-c/manual_tests/
DViewController.m37 GRPCStreamingProtoCall *_call;
117 _call = call;
123 if (_call == nil) return;
131 [_call writeMessage:request];
136 if (_call == nil) return;
138 [_call finish];
139 _call = nil;
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_interceptor.py25 from ._call import UnaryUnaryCall, UnaryStreamCall, StreamUnaryCall, StreamStreamCall, AioRpcError
26 from ._call import _RPC_ALREADY_FINISHED_DETAILS, _RPC_HALF_CLOSED_DETAILS
27 from ._call import _API_STYLE_ERROR
908 _call: Union[_base_call.UnaryStreamCall, _base_call.StreamStreamCall]
915 self._call = call
918 return self._call.cancel()
921 return self._call.cancelled()
924 return self._call.done()
927 self._call.add_done_callback(callback)
930 return self._call.time_remaining()
[all …]
D_channel.py25 from ._call import (StreamStreamCall, StreamUnaryCall, UnaryStreamCall,
/third_party/grpc/src/python/grpcio/grpc/aio/
D_interceptor.py25 from ._call import UnaryUnaryCall, UnaryStreamCall, StreamUnaryCall, StreamStreamCall, AioRpcError
26 from ._call import _RPC_ALREADY_FINISHED_DETAILS, _RPC_HALF_CLOSED_DETAILS
27 from ._call import _API_STYLE_ERROR
907 _call: Union[_base_call.UnaryStreamCall, _base_call.StreamStreamCall]
914 self._call = call
917 return self._call.cancel()
920 return self._call.cancelled()
923 return self._call.done()
926 self._call.add_done_callback(callback)
929 return self._call.time_remaining()
[all …]
D__init__.py32 from ._call import AioRpcError
D_channel.py25 from ._call import (StreamStreamCall, StreamUnaryCall, UnaryStreamCall,
/third_party/grpc/tools/run_tests/python_utils/
Dcheck_on_pr.py84 def _call(url, method='GET', json=None): function
95 resp = _call(
126 resp = _call('/repos/%s/check-runs' % _GITHUB_REPO,
/third_party/grpc/src/python/grpcio/grpc/
D_interceptor.py154 self._call = call
157 return self._call.initial_metadata()
160 return self._call.trailing_metadata()
163 return self._call.code()
166 return self._call.details()
169 return self._call.is_active()
172 return self._call.time_remaining()
175 return self._call.cancel()
178 return self._call.add_callback(callback)
D_channel.py368 self._call = call
391 self._call.cancel(
439 self._call.cancel(
585 event = self._call.next_event()
612 operating = self._call.operate(
778 operating = self._call.operate(
D_server.py341 self._call = call
350 self._call.start_server_batch(
352 _receive_message(self._state, self._call,
/third_party/python/Lib/
Doperator.py246 self._call = func
252 self._call = func
255 return self._call(obj)
278 self._call = func
283 self._call = func
286 return self._call(obj)
/third_party/grpc/src/python/grpcio/grpc/beta/
D_client_adaptations.py79 self._call = call
82 return self._call.cancel()
142 return self._call.is_active()
145 return self._call.time_remaining()
151 abortion_callback(_abortion(self._call))
153 registered = self._call.add_callback(done_callback)
160 return _metadata.beta(self._call.initial_metadata())
163 return _metadata.beta(self._call.terminal_metadata())
166 return self._call.code()
169 return self._call.details()
/third_party/python/Lib/asyncio/
Dbase_subprocess.py194 def _call(self, cb, *data): member in BaseSubprocessTransport
201 self._call(self._protocol.pipe_connection_lost, fd, exc)
205 self._call(self._protocol.pipe_data_received, fd, data)
217 self._call(self._protocol.process_exited)
244 self._call(self._call_connection_lost, None)
/third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/
D_cancel_many_calls_test.py58 self._call = rpc_event.call
69 self._call.start_server_batch(
72 self._call.start_server_batch(
88 self._call.start_server_batch(operations,
/third_party/grpc/src/python/grpcio_testing/grpc_testing/
D_time.py28 def _call(behaviors): function
37 calling = threading.Thread(target=_call, args=(behaviors,))
152 _call(delta.mature_behaviors)
/third_party/python/Lib/unittest/
Dmock.py845 def _call_matcher(self, _call): argument
853 if isinstance(_call, tuple) and len(_call) > 2:
854 sig = self._get_call_signature_from_name(_call[0])
859 if len(_call) == 2:
861 args, kwargs = _call
863 name, args, kwargs = _call
870 return _call
1055 for _call in self:
1056 assert len(item) == len(_call)
1059 for expected, actual in zip(item, _call)
[all …]
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
Daio_rpc_error_test.py22 from grpc.aio._call import AioRpcError
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dchannel.pyx.pxi178 cdef void _call( function
294 _call(
360 _call(
/third_party/python/Lib/test/support/
D__init__.py1396 def _call(self, python, args, env, returncode): member in PythonSymlink
1411 return self._call(self.real, args, None, returncode)
1414 return self._call(self.link, args, self._env, returncode)
/third_party/python/Doc/c-api/
Dcall.rst3 .. _call:

12