Home
last modified time | relevance | path

Searched refs:call_soon (Results 1 - 24 of 24) sorted by relevance

/third_party/python/Lib/asyncio/
H A Dproactor_events.py67 self._loop.call_soon(self._protocol.connection_made, self)
70 self._loop.call_soon(futures._set_result_unless_cancelled,
109 self._loop.call_soon(self._call_connection_lost, None)
152 self._loop.call_soon(self._call_connection_lost, exc)
192 self._loop.call_soon(self._loop_reading)
223 self._loop.call_soon(self._loop_reading, None)
230 self._loop.call_soon(self._data_received, self._data[:length], length)
391 self._loop.call_soon(self._call_connection_lost, None)
473 self._loop.call_soon(self._loop_reading)
527 self._loop.call_soon(sel
[all...]
H A Dtasks.py120 self._loop.call_soon(self.__step, context=self._context)
294 self._loop.call_soon(
300 self._loop.call_soon(
315 self._loop.call_soon(
320 self._loop.call_soon(self.__step, context=self._context)
326 self._loop.call_soon(
331 self._loop.call_soon(
H A Dunix_events.py227 self.call_soon_threadsafe(self.call_soon, transp._process_exited, returncode)
483 self._loop.call_soon(self._protocol.connection_made, self)
485 self._loop.call_soon(self._add_reader,
489 self._loop.call_soon(futures._set_result_unless_cancelled,
536 self._loop.call_soon(self._protocol.eof_received)
537 self._loop.call_soon(self._call_connection_lost, None)
590 self._loop.call_soon(self._call_connection_lost, exc)
627 self._loop.call_soon(self._protocol.connection_made, self)
634 self._loop.call_soon(self._loop._add_reader,
639 self._loop.call_soon(future
[all...]
H A Dbase_subprocess.py181 loop.call_soon(self._protocol.connection_made, self)
183 loop.call_soon(callback, *data)
198 self._loop.call_soon(cb, *data)
H A Dselector_events.py860 self._loop.call_soon(self._call_connection_lost, None)
891 self._loop.call_soon(self._call_connection_lost, exc)
934 self._loop.call_soon(self._protocol.connection_made, self)
936 self._loop.call_soon(self._add_reader,
940 self._loop.call_soon(futures._set_result_unless_cancelled,
1143 self._loop.call_soon(self._protocol.connection_made, self)
1145 self._loop.call_soon(self._add_reader,
1149 self._loop.call_soon(futures._set_result_unless_cancelled,
H A Dfutures.py41 via the event loop's call_soon().
173 self._loop.call_soon(callback, self, context=ctx)
227 scheduled with call_soon.
230 self._loop.call_soon(fn, self, context=context)
H A Dwindows_events.py320 self.call_soon(self._loop_self_reading)
372 self.call_soon(loop_accept_pipe)
384 self.call_soon(loop_accept_pipe)
392 self.call_soon(loop_accept_pipe)
H A Dsslproto.py409 self._loop.call_soon(self._app_protocol.connection_lost, exc)
662 self._loop.call_soon(self._transport.close)
761 self._loop.call_soon(lambda: self._do_read())
870 self._loop.call_soon(resume)
H A Dtimeouts.py68 self._timeout_handler = loop.call_soon(self._on_timeout)
H A Devents.py260 def call_soon(self, callback, *args, context=None): member in AbstractEventLoop
778 When called from a coroutine or a callback (e.g. scheduled with call_soon
H A Dbase_events.py751 def call_soon(self, callback, *args, context=None): member in BaseEventLoop
764 self._check_callback(callback, 'call_soon')
805 """Like call_soon(), but thread-safe."""
1263 conmade_cb = self.call_soon(ssl_protocol.connection_made, transport)
1264 resume_cb = self.call_soon(transport.resume_reading)
/third_party/python/Lib/test/test_asyncio/
H A Dtest_base_events.py238 h = self.loop.call_soon(cb)
246 self.loop.call_soon(1)
301 loop.call_soon(cb)
307 loop.call_soon(cb)
335 loop.call_soon(event.set)
389 handle = loop.call_soon(lambda: True)
499 self.loop.call_soon(throw)
563 # Test call_soon (events.Handle)
566 self.loop.call_soon(zero_error, fut)
611 handle = self.loop.call_soon(zero_erro
[all...]
H A Dtest_streams.py155 self.loop.call_soon(cb)
179 self.loop.call_soon(cb)
194 self.loop.call_soon(cb)
237 self.loop.call_soon(cb)
295 self.loop.call_soon(cb)
309 self.loop.call_soon(cb)
493 self.loop.call_soon(cb)
515 self.loop.call_soon(cb)
H A Dtest_events.py328 self.loop.call_soon(callback, 'hello', 'world')
350 self.loop.call_soon(callback, 'world')
364 self.loop.call_soon(callback, 'world')
391 self.loop.call_soon = patched_call_soon
415 self.loop.call_soon(w.send, b'abc')
417 self.loop.call_soon(w.send, b'def')
419 self.loop.call_soon(w.close)
420 self.loop.call_soon(self.loop.stop)
732 loop.call_soon(loop.stop)
1659 self.loop.call_soon(
[all...]
H A Dtest_proactor_events.py827 call_soon = self.loop.call_soon = mock.Mock()
830 self.assertTrue(call_soon.called)
833 loop = call_soon.call_args[0][0]
854 call_soon = self.loop.call_soon = mock.Mock()
857 loop = call_soon.call_args[0][0]
H A Dtest_locks.py142 asyncio.get_running_loop().call_soon(task.cancel)
223 loop.call_soon(trigger)
349 asyncio.get_running_loop().call_soon(wait.cancel)
463 asyncio.get_running_loop().call_soon(wait.cancel)
483 asyncio.get_running_loop().call_soon(wait_task.cancel)
484 asyncio.get_running_loop().call_soon(cond.release)
871 asyncio.get_running_loop().call_soon(acquire.cancel)
H A Dtest_subprocess.py461 self.loop.call_soon(task.cancel)
482 self.loop.call_soon(task.cancel)
500 self.loop.call_soon(task.cancel)
H A Dtest_waitfor.py278 loop.call_soon(wait.cancel)
H A Dutils.py128 loop.call_soon(loop.stop)
H A Dtest_windows_events.py51 loop.call_soon(thread.start)
H A Dtest_tasks.py677 loop.call_soon(t.cancel)
764 loop.call_soon(inner_task.cancel, 'msg')
2179 def call_soon(callback, *args, **kwargs): function
2181 self.loop.call_soon = call_soon
2302 loop.call_soon(fut.set_result, None)
2469 self.loop.call_soon(lambda: fut.set_result('spam'))
3301 self.loop.call_soon(inc_result, 1)
3304 self.assertEqual(result, 1) # inc'ed by call_soon
H A Dtest_ssl.py278 self.loop.call_soon(srv.close)
569 loop.call_soon(loop.stop)
1171 self.loop.call_soon(srv.close)
H A Dtest_sock_lowlevel.py437 self.loop.call_soon(
/third_party/python/Modules/
H A D_asynciomodule.c22 _Py_IDENTIFIER(call_soon); variable
354 call_soon(PyObject *loop, PyObject *func, PyObject *arg, PyObject *ctx) in call_soon() function
365 /* Use FASTCALL to pass a keyword-only argument to call_soon */ in call_soon()
430 int ret = call_soon( in future_schedule_callbacks()
464 if (call_soon(fut->fut_loop, cb, (PyObject *)fut, ctx)) { in future_schedule_callbacks()
685 if (call_soon(fut->fut_loop, arg, (PyObject*) fut, ctx)) { in future_add_done_callback()
963 scheduled with call_soon.
2578 int ret = call_soon(task->task_loop, cb, NULL, task->task_context); in task_call_step_soon()
3116 call_soon or similar API), this function will always return the

Completed in 36 milliseconds