Searched refs:agen (Results 1 – 11 of 11) sorted by relevance
| /third_party/python/Lib/test/ |
| D | test_asyncgen.py | 469 async def agen(): function
472 self.check_async_iterator_anext(agen)
648 agen = agenfn()
649 with contextlib.closing(anext(agen, "default").__await__()) as g:
661 agen = agenfn()
662 with contextlib.closing(anext(agen, "default").__await__()) as g:
669 agen = agenfn()
670 with contextlib.closing(anext(agen, "default").__await__()) as g:
690 agen = agenfn()
691 with contextlib.closing(anext(agen, "default").__await__()) as g:
[all …]
|
| /third_party/grpc/test/core/end2end/fuzzers/server_fuzzer_corpus/ |
| D | 4db3d4075ed27f2a2311f85dd1d6df028cc5d083 | 12 user-agen"bad-client grpc-c/0.12.0.0 (linux)hority�������� localhosPRI * HTTP/2.0
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| D | common.pyx.pxi | 119 def async_generator_to_generator(object agen, object loop): argument
124 agen.__anext__(),
|
| /third_party/python/Lib/asyncio/ |
| D | base_events.py | 516 def _asyncgen_finalizer_hook(self, agen): argument
517 self._asyncgens.discard(agen)
519 self.call_soon_threadsafe(self.create_task, agen.aclose())
521 def _asyncgen_firstiter_hook(self, agen): argument
528 self._asyncgens.add(agen)
546 for result, agen in zip(results, closing_agens):
552 'asyncgen': agen
|
| /third_party/python/Objects/ |
| D | genobject.c | 56 PyAsyncGenObject *agen = (PyAsyncGenObject*)self; in _PyGen_Finalize() local
57 PyObject *finalizer = agen->ag_finalizer; in _PyGen_Finalize()
58 if (finalizer && !agen->ag_closed) { in _PyGen_Finalize()
|
| /third_party/python/Doc/reference/ |
| D | expressions.rst | 432 async def agen(): # defines an asynchronous generator function
642 :meth:`~agen.__anext__` is used then the result is :const:`None`. Otherwise, if
643 :meth:`~agen.asend` is used, then the result will be the value passed in to that
653 :meth:`~agen.aclose` method to finalize the generator and ultimately detach it
663 generator-iterator's :meth:`~agen.aclose` method and run the resulting
669 presumably calls :meth:`~agen.aclose` and executes the coroutine.
691 .. coroutinemethod:: agen.__anext__()
695 asynchronous generator function is resumed with an :meth:`~agen.__anext__`
708 .. coroutinemethod:: agen.asend(value)
723 .. coroutinemethod:: agen.athrow(type[, value[, traceback]])
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Target/PowerPC/ |
| D | PPCScheduleP8.td | 256 // dispatch slot. The instruction will be broken into two IOPS. The agen
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_base_events.py | 938 async def agen(): function
946 ag = agen()
|
| /third_party/python/Doc/whatsnew/ |
| D | 3.9.rst | 259 * Parallel running of :meth:`~agen.aclose` / :meth:`~agen.asend` /
260 :meth:`~agen.athrow` is now prohibited, and ``ag_running`` now reflects
|
| /third_party/python/Doc/library/ |
| D | inspect.rst | 370 >>> async def agen():
373 >>> inspect.isasyncgenfunction(agen)
|
| D | asyncio-eventloop.rst | 163 close with an :meth:`~agen.aclose()` call. After calling this method,
|