| /external/python/futures/ |
| D | test_futures.py | 106 def create_future(state=PENDING, exception=None, result=None): function
114 PENDING_FUTURE = create_future(state=PENDING)
115 RUNNING_FUTURE = create_future(state=RUNNING)
116 CANCELLED_FUTURE = create_future(state=CANCELLED)
117 CANCELLED_AND_NOTIFIED_FUTURE = create_future(state=CANCELLED_AND_NOTIFIED)
118 EXCEPTION_FUTURE = create_future(state=FINISHED, exception=IOError())
119 SUCCESSFUL_FUTURE = create_future(state=FINISHED, result=42)
646 f1 = create_future(state=PENDING)
647 f2 = create_future(state=RUNNING)
648 f3 = create_future(state=CANCELLED)
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 31 def create_future(state=PENDING, exception=None, result=None): function
39 PENDING_FUTURE = create_future(state=PENDING)
40 RUNNING_FUTURE = create_future(state=RUNNING)
41 CANCELLED_FUTURE = create_future(state=CANCELLED)
42 CANCELLED_AND_NOTIFIED_FUTURE = create_future(state=CANCELLED_AND_NOTIFIED)
43 EXCEPTION_FUTURE = create_future(state=FINISHED, exception=OSError())
44 SUCCESSFUL_FUTURE = create_future(state=FINISHED, result=42)
619 futures_list.append(create_future(state=CANCELLED_AND_NOTIFIED))
620 futures_list.append(create_future(state=FINISHED, result=42))
1091 f1 = create_future(state=PENDING)
[all …]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_sslproto.py | 254 on_data = self.loop.create_future()
255 on_eof = self.loop.create_future()
334 on_data1 = self.loop.create_future()
335 on_data2 = self.loop.create_future()
336 on_eof = self.loop.create_future()
368 server_waits_on_handshake = self.loop.create_future()
405 on_data = self.loop.create_future()
406 on_eof = self.loop.create_future()
489 on_con = self.loop.create_future()
490 on_eof = self.loop.create_future()
[all …]
|
| D | test_buffered_proto.py | 44 conn_lost_fut = self.loop.create_future()
|
| D | test_base_events.py | 982 def __init__(self, create_future=False): argument
985 if create_future:
1012 def __init__(self, create_future=False, loop=None): argument
1015 if create_future:
1379 self.loop.sock_connect.return_value = self.loop.create_future()
1499 getaddrinfo.return_value = self.loop.create_future()
1630 lambda: MyDatagramProto(create_future=True, loop=self.loop),
1640 lambda: MyDatagramProto(create_future=True, loop=self.loop),
1690 lambda: MyDatagramProto(create_future=True, loop=self.loop),
1720 lambda: MyDatagramProto(create_future=True, loop=self.loop),
[all …]
|
| D | test_unix_events.py | 434 self.fut = loop.create_future()
436 self._ready = loop.create_future()
545 fut = self.loop.create_future()
558 fut = self.loop.create_future()
585 fut = self.loop.create_future()
599 fut = self.loop.create_future()
616 fut = self.loop.create_future()
|
| D | test_selector_events.py | 461 resolved = self.loop.create_future()
490 resolved = self.loop.create_future()
|
| D | test_proactor_events.py | 875 self.fut = loop.create_future()
|
| D | test_events.py | 2153 self.fut = loop.create_future()
2537 fut = self.loop.create_future()
|
| /external/python/cpython3/Lib/asyncio/ |
| D | locks.py | 184 fut = self._loop.create_future()
290 fut = self._loop.create_future()
351 fut = self._loop.create_future()
471 fut = self._loop.create_future()
|
| D | tasks.py | 399 waiter = loop.create_future()
434 waiter = loop.create_future()
474 waiter = loop.create_future()
563 future = loop.create_future()
660 outer = loop.create_future()
774 outer = loop.create_future()
|
| D | queues.py | 118 putter = self._loop.create_future()
156 getter = self._loop.create_future()
|
| D | base_events.py | 190 self._write_ready_fut = self._transport._loop.create_future()
220 self._write_ready_fut = self._transport._loop.create_future()
337 self._serving_forever_fut = self._loop.create_future()
353 waiter = self._loop.create_future()
394 def create_future(self): member in BaseEventLoop
1003 waiter = self.create_future()
1118 waiter = self.create_future()
1248 waiter = self.create_future()
1437 waiter = self.create_future()
1453 waiter = self.create_future()
|
| D | selector_events.py | 198 waiter = self.create_future()
350 fut = self.create_future()
383 fut = self.create_future()
420 fut = self.create_future()
462 fut = self.create_future()
513 fut = self.create_future()
921 self._empty_waiter = self._loop.create_future()
|
| D | streams.py | 207 waiter = self._loop.create_future()
227 self._closed = self._loop.create_future()
471 self._waiter = self._loop.create_future()
|
| D | futures.py | 376 new_future = loop.create_future()
|
| D | base_subprocess.py | 232 waiter = self._loop.create_future()
|
| D | windows_events.py | 368 waiter = self.create_future()
418 fut = self._loop.create_future()
|
| D | unix_events.py | 186 waiter = self.create_future()
336 fut = self.create_future()
|
| D | events.py | 275 def create_future(self): member in AbstractEventLoop
|
| D | proactor_events.py | 397 self._empty_waiter = self._loop.create_future()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-future.rst | 79 :meth:`loop.create_future`. This way alternative event loop
212 fut = loop.create_future()
|
| D | asyncio-protocol.rst | 792 on_con_lost = loop.create_future()
876 self.on_con_lost = loop.create_future()
932 self.on_con_lost = loop.create_future()
|
| D | asyncio-llapi-index.rst | 117 * - :meth:`loop.create_future`
|
| /external/python/cpython3/Misc/NEWS.d/ |
| D | 3.5.2rc1.rst | 1624 asyncio: Add loop.create_future method
|