Searched refs:call_soon (Results 1 – 25 of 33) sorted by relevance
12
66 self._loop.call_soon(self._protocol.connection_made, self)69 self._loop.call_soon(futures._set_result_unless_cancelled,108 self._loop.call_soon(self._call_connection_lost, None)151 self._loop.call_soon(self._call_connection_lost, exc)188 self._loop.call_soon(self._loop_reading)219 self._loop.call_soon(self._loop_reading, None)226 self._loop.call_soon(self._data_received, self._data[:length], length)387 self._loop.call_soon(self._call_connection_lost, None)467 self._loop.call_soon(self._loop_reading)520 self._loop.call_soon(self._call_connection_lost, None)[all …]
112 self._loop.call_soon(self.__step, context=self._context)259 self._loop.call_soon(265 self._loop.call_soon(280 self._loop.call_soon(285 self._loop.call_soon(self.__step, context=self._context)291 self._loop.call_soon(296 self._loop.call_soon(
471 self._loop.call_soon(self._protocol.connection_made, self)473 self._loop.call_soon(self._loop._add_reader,477 self._loop.call_soon(futures._set_result_unless_cancelled,516 self._loop.call_soon(self._protocol.eof_received)517 self._loop.call_soon(self._call_connection_lost, None)570 self._loop.call_soon(self._call_connection_lost, exc)607 self._loop.call_soon(self._protocol.connection_made, self)614 self._loop.call_soon(self._loop._add_reader,619 self._loop.call_soon(futures._set_result_unless_cancelled,731 self._loop.call_soon(self._call_connection_lost, None)[all …]
181 loop.call_soon(self._protocol.connection_made, self)183 loop.call_soon(callback, *data)198 self._loop.call_soon(cb, *data)
700 self._loop.call_soon(self._call_connection_lost, None)731 self._loop.call_soon(self._call_connection_lost, exc)776 self._loop.call_soon(self._protocol.connection_made, self)778 self._loop.call_soon(self._add_reader,782 self._loop.call_soon(futures._set_result_unless_cancelled,1003 self._loop.call_soon(self._protocol.connection_made, self)1005 self._loop.call_soon(self._add_reader,1009 self._loop.call_soon(futures._set_result_unless_cancelled,
171 self._loop.call_soon(callback, self, context=ctx)228 self._loop.call_soon(fn, self, context=context)
491 self._loop.call_soon(self._app_protocol.connection_lost, exc)663 self._loop.call_soon(self._process_write_backlog)
320 self.call_soon(self._loop_self_reading)387 self.call_soon(loop_accept_pipe)
735 def call_soon(self, callback, *args, context=None): member in BaseEventLoop1226 conmade_cb = self.call_soon(ssl_protocol.connection_made, transport)1227 resume_cb = self.call_soon(transport.resume_reading)
261 def call_soon(self, callback, *args, context=None): member in AbstractEventLoop
240 h = self.loop.call_soon(cb)248 self.loop.call_soon(1)299 loop.call_soon(cb)305 loop.call_soon(cb)333 loop.call_soon(event.set)387 handle = loop.call_soon(lambda: True)497 self.loop.call_soon(throw)564 self.loop.call_soon(zero_error, fut)617 handle = self.loop.call_soon(zero_error)652 self.loop.call_soon(zero_error)[all …]
149 asyncio.get_running_loop().call_soon(task.cancel)230 loop.call_soon(trigger)356 asyncio.get_running_loop().call_soon(wait.cancel)470 asyncio.get_running_loop().call_soon(wait.cancel)490 asyncio.get_running_loop().call_soon(wait_task.cancel)491 asyncio.get_running_loop().call_soon(cond.release)880 asyncio.get_running_loop().call_soon(acquire.cancel)
155 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)
779 call_soon = self.loop.call_soon = mock.Mock()782 self.assertTrue(call_soon.called)785 loop = call_soon.call_args[0][0]806 call_soon = self.loop.call_soon = mock.Mock()809 loop = call_soon.call_args[0][0]
327 self.loop.call_soon(callback, 'hello', 'world')349 self.loop.call_soon(callback, 'world')363 self.loop.call_soon(callback, 'world')390 self.loop.call_soon = patched_call_soon414 self.loop.call_soon(w.send, b'abc')416 self.loop.call_soon(w.send, b'def')418 self.loop.call_soon(w.close)419 self.loop.call_soon(self.loop.stop)690 loop.call_soon(loop.stop)1625 self.loop.call_soon(f.cancel)[all …]
412 self.loop.call_soon(task.cancel)433 self.loop.call_soon(task.cancel)451 self.loop.call_soon(task.cancel)
51 loop.call_soon(thread.start)
644 loop.call_soon(t.cancel)2552 loop.call_soon(wait.cancel)2654 def call_soon(callback, *args, **kwargs): function2656 self.loop.call_soon = call_soon2796 loop.call_soon(fut.set_result, None)2879 self.loop.call_soon(lambda: fut.set_result('spam'))3709 self.loop.call_soon(inc_result, 1)
128 loop.call_soon(loop.stop)
164 the callback is scheduled with :meth:`loop.call_soon`.271 :meth:`loop.call_soon` instead.
83 methods such as :meth:`loop.call_soon` and :meth:`loop.call_later`;197 .. method:: loop.call_soon(callback, *args, context=None)216 A thread-safe variant of :meth:`call_soon`. Must be used to238 loop.call_soon(1373 A callback wrapper object returned by :meth:`loop.call_soon`,1567 and :meth:`loop.call_soon`. Modern asyncio applications rarely1574 Hello World with call_soon()1577 An example using the :meth:`loop.call_soon` method to schedule a1591 loop.call_soon(hello_world, loop)1628 loop.call_soon(display_date, end_time, loop)[all …]
86 * - :meth:`loop.call_soon`90 - A thread-safe variant of :meth:`loop.call_soon`.
53 * Many non-threadsafe asyncio APIs (such as :meth:`loop.call_soon` and
16 _Py_IDENTIFIER(call_soon);353 call_soon(PyObject *loop, PyObject *func, PyObject *arg, PyObject *ctx) in call_soon() function429 int ret = call_soon( in future_schedule_callbacks()463 if (call_soon(fut->fut_loop, cb, (PyObject *)fut, ctx)) { in future_schedule_callbacks()665 if (call_soon(fut->fut_loop, arg, (PyObject*) fut, ctx)) { in future_add_done_callback()2543 int ret = call_soon(task->task_loop, cb, NULL, task->task_context); in task_call_step_soon()
188 Optimize loop.call_soon.