Home
last modified time | relevance | path

Searched refs:add_done_callback (Results 1 – 25 of 52) sorted by relevance

123

/third_party/python/Lib/test/test_asyncio/
Dtest_futures.py193 fut.add_done_callback(lambda f: None)
345 f_one_callbacks.add_done_callback(_fakefunc)
355 f_two_callbacks.add_done_callback(first_cb)
356 f_two_callbacks.add_done_callback(last_cb)
364 f_many_callbacks.add_done_callback(first_cb)
366 f_many_callbacks.add_done_callback(_fakefunc)
367 f_many_callbacks.add_done_callback(last_cb)
686 f.add_done_callback(cb1)
687 f.add_done_callback(cb2)
688 f.add_done_callback(cb3)
[all …]
/third_party/python/Lib/asyncio/
Dtasks.py269 result.add_done_callback(
427 fut.add_done_callback(cb)
488 f.add_done_callback(_on_completion)
512 fut.add_done_callback(cb)
574 f.add_done_callback(_on_completion)
788 fut.add_done_callback(_done_callback)
854 inner.add_done_callback(_inner_done_callback)
855 outer.add_done_callback(_outer_done_callback)
Dproactor_events.py317 self._read_fut.add_done_callback(self._loop_reading)
401 self._write_fut.add_done_callback(self._loop_writing)
404 self._write_fut.add_done_callback(self._loop_writing)
437 self._read_fut.add_done_callback(self._pipe_closed)
536 self._write_fut.add_done_callback(self._loop_writing)
577 self._read_fut.add_done_callback(self._loop_reading)
793 f.add_done_callback(self._loop_self_reading)
852 f.add_done_callback(loop)
Dfutures.py220 def add_done_callback(self, fn, *, context=None): member in Future
400 destination.add_done_callback(_call_check_cancel)
401 source.add_done_callback(_call_set_state)
Dselector_events.py371 fut.add_done_callback(
412 fut.add_done_callback(
460 fut.add_done_callback(
516 fut.add_done_callback(
571 fut.add_done_callback(
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
D_common.py60 call.add_done_callback(first_callback)
61 call.add_done_callback(second_callback)
Dclient_unary_unary_interceptor_test.py615 call.add_done_callback(callback)
652 call.add_done_callback(callback)
685 call.add_done_callback(callback)
/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_channel_ready_future_test.py50 ready_future.add_done_callback(callback.accept_value)
76 ready_future.add_done_callback(callback.accept_value)
D_rpc_part_1_test.py71 response_future.add_done_callback(callback)
125 response_future.add_done_callback(callback)
175 response_future.add_done_callback(callback)
D_rpc_test.py614 response_future.add_done_callback(callback)
676 response_future.add_done_callback(callback)
730 response_future.add_done_callback(callback)
780 response_future.add_done_callback(callback)
D_channel_close_test.py214 future.add_done_callback(on_done_callback)
/third_party/grpc/src/python/grpcio_tests/tests/unit/beta/
D_utilities_test.py52 ready_future.add_done_callback(callback.accept_value)
74 ready_future.add_done_callback(callback.accept_value)
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_interceptor.py277 self._interceptors_task.add_done_callback(
306 call.add_done_callback(callback)
354 def add_done_callback(self, callback: DoneCallbackType) -> None: member in InterceptedCall
369 call.add_done_callback(callback)
874 def add_done_callback(self, unused_callback) -> None: member in UnaryUnaryCallResponse
926 def add_done_callback(self, callback) -> None: member in _StreamCallResponseIterator
927 self._call.add_done_callback(callback)
D_base_call.py76 def add_done_callback(self, callback: DoneCallbackType) -> None: member in RpcContext
D_call.py200 def add_done_callback(self, callback: DoneCallbackType) -> None: member in Call
202 self._cython_call.add_done_callback(cb)
/third_party/grpc/src/python/grpcio/grpc/aio/
D_interceptor.py277 self._interceptors_task.add_done_callback(
305 call.add_done_callback(callback)
353 def add_done_callback(self, callback: DoneCallbackType) -> None: member in InterceptedCall
368 call.add_done_callback(callback)
873 def add_done_callback(self, unused_callback) -> None: member in UnaryUnaryCallResponse
925 def add_done_callback(self, callback) -> None: member in _StreamCallResponseIterator
926 self._call.add_done_callback(callback)
D_base_call.py76 def add_done_callback(self, callback: DoneCallbackType) -> None: member in RpcContext
D_call.py200 def add_done_callback(self, callback: DoneCallbackType) -> None: member in Call
202 self._cython_call.add_done_callback(cb)
/third_party/grpc/src/python/grpcio/grpc/framework/foundation/
Dfuture.py209 def add_done_callback(self, fn): member in Future
/third_party/grpc/examples/python/interceptors/default_value/
Ddefault_value_client_interceptor.py45 def add_done_callback(self, fn): member in _ConcreteValue
/third_party/python/Lib/test/
Dtest_concurrent_futures.py1277 f.add_done_callback(fn)
1288 f.add_done_callback(fn)
1299 f.add_done_callback(fn)
1318 f.add_done_callback(raising_fn)
1319 f.add_done_callback(fn)
1333 f.add_done_callback(fn)
1344 f.add_done_callback(fn)
1355 f.add_done_callback(fn)
1368 f.add_done_callback(raising_fn)
/third_party/python/Doc/library/
Dasyncio-future.rst156 .. method:: add_done_callback(callback, *, context=None)
174 fut.add_done_callback(
269 - Callbacks registered with :meth:`asyncio.Future.add_done_callback`
/third_party/grpc/src/python/grpcio/grpc/beta/
Dutilities.py114 def add_done_callback(self, fn): member in _ChannelReadyFuture
/third_party/grpc/src/python/grpcio/grpc/
D_utilities.py148 def add_done_callback(self, fn): member in _ChannelReadyFuture
D_interceptor.py137 def add_done_callback(self, fn): member in _FailureOutcome
198 def add_done_callback(self, fn): member in _UnaryOutcome

123