Home
last modified time | relevance | path

Searched refs:create_future (Results 1 – 25 of 45) sorted by relevance

12

/third_party/python/Lib/test/test_asyncio/
Dtest_sslproto.py76 waiter = self.loop.create_future()
87 waiter = self.loop.create_future()
101 waiter = self.loop.create_future()
110 waiter = self.loop.create_future()
120 waiter = self.loop.create_future()
131 waiter = self.loop.create_future()
259 on_data = self.loop.create_future()
260 on_eof = self.loop.create_future()
324 on_data = self.loop.create_future()
325 on_eof = self.loop.create_future()
[all …]
Dtest_proactor_events.py52 fut = self.loop.create_future()
68 res = self.loop.create_future()
81 res = self.loop.create_future()
191 fut = self.loop.create_future()
200 fut = self.loop.create_future()
269 fut = self.loop.create_future()
312 f = self.loop.create_future()
336 f = self.loop.create_future()
364 f = self.loop.create_future()
426 fut = self.loop.create_future()
[all …]
Dtest_base_events.py195 f = self.loop.create_future()
332 fut = loop.create_future()
480 task = self.loop.create_future()
563 fut = self.loop.create_future()
573 fut = self.loop.create_future()
1000 def __init__(self, create_future=False): argument
1003 if create_future:
1004 self.done = asyncio.get_running_loop().create_future()
1034 def __init__(self, create_future=False, loop=None): argument
1037 if create_future:
[all …]
Dtest_buffered_proto.py48 conn_lost_fut = self.loop.create_future()
Dtest_sendfile.py34 self.connected = loop.create_future()
35 self.done = loop.create_future()
75 self.fut = loop.create_future()
496 fut = self.loop.create_future()
Dtest_unix_events.py458 self.fut = loop.create_future()
460 self._ready = loop.create_future()
569 fut = self.loop.create_future()
582 fut = self.loop.create_future()
609 fut = self.loop.create_future()
623 fut = self.loop.create_future()
640 fut = self.loop.create_future()
682 waiter = self.loop.create_future()
859 waiter = self.loop.create_future()
Dtest_events.py87 self.connected = loop.create_future()
88 self.done = loop.create_future()
129 self.done = loop.create_future()
162 self.done = loop.create_future()
197 self.done = loop.create_future()
220 self.connected = loop.create_future()
221 self.completed = loop.create_future()
222 self.disconnects = {fd: loop.create_future() for fd in range(3)}
1139 proto = self.loop.create_future()
1178 f_proto = self.loop.create_future()
[all …]
Dtest_tasks.py121 self.loop.create_future = lambda: self.new_future(self.loop)
3289 a, b, c = [self.one_loop.create_future() for i in range(3)]
3311 a, b, c, d, e = [self.one_loop.create_future() for i in range(5)]
3329 a, b, c, d = [self.one_loop.create_future() for i in range(4)]
3416 fut1 = self.one_loop.create_future()
3417 fut2 = self.other_loop.create_future()
3422 children = [self.other_loop.create_future() for i in range(3)]
3433 a, b, c, d, e = [self.one_loop.create_future() for i in range(5)]
3451 a, b, c, d, e, f = [self.one_loop.create_future()
3539 waiter = self.one_loop.create_future()
[all …]
Dtest_sock_lowlevel.py23 self.connected = loop.create_future()
24 self.done = loop.create_future()
Dtest_selector_events.py81 waiter = self.loop.create_future()
157 f = self.loop.create_future()
519 waiter = self.loop.create_future()
528 waiter = self.loop.create_future()
914 waiter = self.loop.create_future()
/third_party/python/Lib/test/
Dtest_concurrent_futures.py35 def create_future(state=PENDING, exception=None, result=None): function
43 PENDING_FUTURE = create_future(state=PENDING)
44 RUNNING_FUTURE = create_future(state=RUNNING)
45 CANCELLED_FUTURE = create_future(state=CANCELLED)
46 CANCELLED_AND_NOTIFIED_FUTURE = create_future(state=CANCELLED_AND_NOTIFIED)
47 EXCEPTION_FUTURE = create_future(state=FINISHED, exception=OSError())
48 SUCCESSFUL_FUTURE = create_future(state=FINISHED, result=42)
765 futures_list.append(create_future(state=CANCELLED_AND_NOTIFIED))
766 futures_list.append(create_future(state=FINISHED, result=42))
1392 f1 = create_future(state=PENDING)
[all …]
/third_party/python/Lib/asyncio/
Dlocks.py105 fut = self._get_loop().create_future()
210 fut = self._get_loop().create_future()
265 fut = self._get_loop().create_future()
382 fut = self._get_loop().create_future()
Dtasks.py422 waiter = loop.create_future()
469 waiter = loop.create_future()
510 waiter = loop.create_future()
600 future = loop.create_future()
710 outer = loop.create_future()
831 outer = loop.create_future()
Dqueues.py118 putter = self._get_loop().create_future()
156 getter = self._get_loop().create_future()
Dbase_events.py216 self._write_ready_fut = self._transport._loop.create_future()
246 self._write_ready_fut = self._transport._loop.create_future()
363 self._serving_forever_fut = self._loop.create_future()
379 waiter = self._loop.create_future()
422 def create_future(self): member in BaseEventLoop
560 future = self.create_future()
1099 waiter = self.create_future()
1214 waiter = self.create_future()
1365 waiter = self.create_future()
1546 waiter = self.create_future()
[all …]
Dstreams.py176 waiter = self._loop.create_future()
212 self._closed = self._loop.create_future()
312 self._complete_fut = self._loop.create_future()
500 self._waiter = self._loop.create_future()
Dselector_events.py206 waiter = self.create_future()
367 fut = self.create_future()
408 fut = self.create_future()
454 fut = self.create_future()
500 fut = self.create_future()
559 fut = self.create_future()
986 self._empty_waiter = self._loop.create_future()
Dwindows_events.py393 waiter = self.create_future()
445 fut = self._loop.create_future()
586 fut = self._loop.create_future()
Dsubprocess.py28 self._stdin_closed = self._loop.create_future()
/third_party/python/Lib/unittest/
Dasync_case.py77 fut = self._asyncioTestLoop.create_future()
85 fut = self._asyncioTestLoop.create_future()
116 fut = loop.create_future()
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
Dclient_unary_stream_interceptor_test.py255 wait_for_ever = self.loop.create_future()
290 wait_for_ever = self.loop.create_future()
Dclient_stream_unary_interceptor_test.py312 wait_for_ever = self.loop.create_future()
355 wait_for_ever = self.loop.create_future()
Dserver_test.py56 self._called = asyncio.get_event_loop().create_future()
107 await asyncio.get_event_loop().create_future()
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/
Dchannel.pyx.pxi83 cdef object future = self.loop.create_future()
/third_party/python/Doc/library/
Dasyncio-future.rst97 :meth:`loop.create_future`. This way alternative event loop
237 fut = loop.create_future()

12