Searched refs:call_soon (Results 1 – 25 of 31) sorted by relevance
12
44 self._loop.call_soon(self._protocol.connection_made, self)47 self._loop.call_soon(futures._set_result_unless_cancelled,86 self._loop.call_soon(self._call_connection_lost, None)130 self._loop.call_soon(self._call_connection_lost, exc)166 self._loop.call_soon(self._loop_reading)197 self._loop.call_soon(self._loop_reading, None)204 self._loop.call_soon(self._data_received, data)360 self._loop.call_soon(self._call_connection_lost, None)616 self.call_soon(self._loop_self_reading)686 self.call_soon(loop)
116 self._loop.call_soon(self.__step, context=self._context)248 self._loop.call_soon(254 self._loop.call_soon(268 self._loop.call_soon(273 self._loop.call_soon(self.__step, context=self._context)279 self._loop.call_soon(284 self._loop.call_soon(
446 self._loop.call_soon(self._protocol.connection_made, self)448 self._loop.call_soon(self._loop._add_reader,452 self._loop.call_soon(futures._set_result_unless_cancelled,491 self._loop.call_soon(self._protocol.eof_received)492 self._loop.call_soon(self._call_connection_lost, None)536 self._loop.call_soon(self._call_connection_lost, exc)573 self._loop.call_soon(self._protocol.connection_made, self)580 self._loop.call_soon(self._loop._add_reader,585 self._loop.call_soon(futures._set_result_unless_cancelled,693 self._loop.call_soon(self._call_connection_lost, None)[all …]
182 loop.call_soon(self._protocol.connection_made, self)184 loop.call_soon(callback, *data)197 self._loop.call_soon(cb, *data)
650 self._loop.call_soon(self._call_connection_lost, None)682 self._loop.call_soon(self._call_connection_lost, exc)727 self._loop.call_soon(self._protocol.connection_made, self)729 self._loop.call_soon(self._add_reader,733 self._loop.call_soon(futures._set_result_unless_cancelled,938 self._loop.call_soon(self._protocol.connection_made, self)940 self._loop.call_soon(self._add_reader,944 self._loop.call_soon(futures._set_result_unless_cancelled,
149 self._loop.call_soon(callback, self, context=ctx)204 self._loop.call_soon(fn, self, context=context)
493 self._loop.call_soon(self._app_protocol.connection_lost, exc)655 self._loop.call_soon(self._process_write_backlog)
678 def call_soon(self, callback, *args, context=None): member in BaseEventLoop1130 conmade_cb = self.call_soon(ssl_protocol.connection_made, transport)1131 resume_cb = self.call_soon(transport.resume_reading)
263 def call_soon(self, callback, *args): member in AbstractEventLoop
362 self.call_soon(loop_accept_pipe)
218 h = self.loop.call_soon(cb)226 self.loop.call_soon(1)277 loop.call_soon(cb)283 loop.call_soon(cb)311 loop.call_soon(event.set)390 handle = loop.call_soon(lambda: True)500 self.loop.call_soon(throw)569 self.loop.call_soon(zero_error, fut)623 handle = self.loop.call_soon(zero_error)658 self.loop.call_soon(zero_error)[all …]
741 def test_ctor(self, socketpair, call_soon): argument748 call_soon.assert_called_with(loop._loop_self_reading)808 call_soon = self.loop.call_soon = mock.Mock()811 self.assertTrue(call_soon.called)814 loop = call_soon.call_args[0][0]835 call_soon = self.loop.call_soon = mock.Mock()838 loop = call_soon.call_args[0][0]
152 self.loop.call_soon(cb)176 self.loop.call_soon(cb)191 self.loop.call_soon(cb)234 self.loop.call_soon(cb)292 self.loop.call_soon(cb)306 self.loop.call_soon(cb)489 self.loop.call_soon(cb)511 self.loop.call_soon(cb)
150 self.loop.call_soon(task.cancel)220 self.loop.call_soon(trigger)413 self.loop.call_soon(wait.cancel)545 self.loop.call_soon(wait.cancel)566 self.loop.call_soon(wait_task.cancel)567 self.loop.call_soon(cond.release)953 self.loop.call_soon(acquire.cancel)
343 self.loop.call_soon(task.cancel)365 self.loop.call_soon(task.cancel)383 self.loop.call_soon(task.cancel)
304 self.loop.call_soon(callback, 'hello', 'world')326 self.loop.call_soon(callback, 'world')340 self.loop.call_soon(callback, 'world')365 self.loop.call_soon = patched_call_soon389 self.loop.call_soon(w.send, b'abc')391 self.loop.call_soon(w.send, b'def')393 self.loop.call_soon(w.close)394 self.loop.call_soon(self.loop.stop)791 loop.call_soon(loop.stop)1722 self.loop.call_soon(f.cancel)[all …]
446 loop.call_soon(t.cancel)2118 loop.call_soon(wait.cancel)2206 def call_soon(callback, *args, **kwargs): function2208 self.loop.call_soon = call_soon2333 loop.call_soon(fut.set_result, None)2407 self.loop.call_soon(lambda: fut.set_result('spam'))3214 self.loop.call_soon(inc_result, 1)
126 loop.call_soon(loop.stop)
142 the callback is scheduled with :meth:`loop.call_soon`.246 :meth:`loop.call_soon` instead.
72 methods such as :meth:`loop.call_soon` and :meth:`loop.call_later`;174 .. method:: loop.call_soon(callback, *args, context=None)193 A thread-safe variant of :meth:`call_soon`. Must be used to211 loop.call_soon(1262 A callback wrapper object returned by :meth:`loop.call_soon`,1466 and :meth:`loop.call_soon`. Modern asyncio applications rarely1473 Hello World with call_soon()1476 An example using the :meth:`loop.call_soon` method to schedule a1490 loop.call_soon(hello_world, loop)1527 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
15 _Py_IDENTIFIER(call_soon);340 call_soon(PyObject *loop, PyObject *func, PyObject *arg, PyObject *ctx) in call_soon() function417 int ret = call_soon( in future_schedule_callbacks()451 if (call_soon(fut->fut_loop, cb, (PyObject *)fut, ctx)) { in future_schedule_callbacks()629 if (call_soon(fut->fut_loop, arg, (PyObject*) fut, ctx)) { in future_add_done_callback()2465 int ret = call_soon(task->task_loop, cb, NULL, task->task_context); in task_call_step_soon()
188 Optimize loop.call_soon.
129 start immediately the handshake instead of using call_soon(). Previously,