/dports/devel/folly/folly-2021.12.27.00/folly/experimental/coro/test/ |
H A D | MultiplexTest.cpp | 37 auto makeStreamOfStreams = []() -> AsyncGenerator<AsyncGenerator<int>> { in TEST_F() 38 auto ints = [](int n) -> AsyncGenerator<int> { in TEST_F() 45 auto failing = []() -> AsyncGenerator<int> { in TEST_F()
|
H A D | DematerializeTest.cpp | 43 auto selectStream = [](int index) -> AsyncGenerator<int> { in TEST_F() 44 auto ints = [](int n) -> AsyncGenerator<int> { in TEST_F() 51 auto failing = []() -> AsyncGenerator<int> { in TEST_F() 102 []() -> folly::coro::AsyncGenerator<std::unique_ptr<int>&&> { in TEST_F() 139 auto makeGenerator = []() -> folly::coro::AsyncGenerator<MoveOnly> { in TEST_F()
|
H A D | AsyncGeneratorBenchmark.cpp | 36 auto gen = []() -> folly::coro::AsyncGenerator<int> { in BENCHMARK() 54 auto gen = []() -> folly::coro::AsyncGenerator<int> { in BENCHMARK() 72 auto gen = []() -> folly::coro::AsyncGenerator<int> { in BENCHMARK() 90 auto gen = []() -> folly::coro::AsyncGenerator<int> { in BENCHMARK()
|
H A D | TransformTest.cpp | 48 auto selectStream = [](int index) -> AsyncGenerator<int> { in TEST_F() 49 auto ints = [](int n) -> AsyncGenerator<int> { in TEST_F() 56 auto failing = []() -> AsyncGenerator<int> { in TEST_F() 109 folly::coro::AsyncGenerator<Ref, Value> neverStream() { in neverStream()
|
H A D | MaterializeTest.cpp | 43 auto selectStream = [](int index) -> AsyncGenerator<int> { in TEST_F() 44 auto ints = [](int n) -> AsyncGenerator<int> { in TEST_F() 51 auto failing = []() -> AsyncGenerator<int> { in TEST_F()
|
H A D | TimeoutTest.cpp | 167 TEST(Timeout, AsyncGenerator) { in TEST() argument 171 []() -> coro::AsyncGenerator<int> { co_yield 42; }().next(), 1s); in TEST() 176 []() -> coro::AsyncGenerator<int> { in TEST() 185 []() -> coro::AsyncGenerator<int> { co_return; }().next(), 1s); in TEST()
|
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/coro/ |
H A D | Merge.h | 44 AsyncGenerator<Reference, Value> merge( 46 AsyncGenerator<AsyncGenerator<Reference, Value>> sources);
|
H A D | Concat.h | 53 AsyncGenerator<HReference, HValue> concat( 54 AsyncGenerator<HReference, HValue> head, 55 AsyncGenerator<TReference, TValue>... tail);
|
H A D | Dematerialize.h | 57 AsyncGenerator<Reference, Value> dematerialize( 58 AsyncGenerator<CallbackRecord<Reference>, CallbackRecord<Value>> source);
|
H A D | Filter.h | 40 AsyncGenerator<Reference, Value> filter( 41 AsyncGenerator<Reference, Value> source, FilterFn filterFn);
|
H A D | Transform.h | 53 AsyncGenerator<invoke_result_t<TransformFn&, Reference>> transform( 54 AsyncGenerator<Reference, Value> source, TransformFn transformFn);
|
/dports/devel/folly/folly-2021.12.27.00/folly/python/ |
H A D | async_generator.h | 30 using NextResult = typename coro::AsyncGenerator<T>::NextResult; 36 explicit AsyncGeneratorWrapper(coro::AsyncGenerator<T>&& gen) in AsyncGeneratorWrapper() 42 coro::AsyncGenerator<T> gen_;
|
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/testing/ |
H A D | async_test_util.h | 32 explicit TrackingGenerator(AsyncGenerator<T> source) in TrackingGenerator() 44 explicit State(AsyncGenerator<T> source) : source(std::move(source)), num_read(0) {} in State() 46 AsyncGenerator<T> source;
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/py3/test/stream/ |
H A D | test_client.py | 18 from typing import AsyncGenerator, Tuple, Optional 36 ) -> AsyncGenerator[int, None]: 40 async def alwaysThrows(self) -> AsyncGenerator[int, None]: 44 async def stringstream(self) -> AsyncGenerator[str, None]: 53 async def streamthrows(self, t: bool) -> AsyncGenerator[int, None]: 62 ) -> Tuple[Included, AsyncGenerator[Included, None]]: 65 async def inner() -> AsyncGenerator[Included, None]:
|
/dports/devel/py-mypy/mypy-0.910/test-data/unit/ |
H A D | check-async-await.test | 436 async def g() -> AsyncGenerator[int, None]: 475 from typing import AsyncGenerator 493 from typing import AsyncGenerator 514 from typing import AsyncGenerator 533 from typing import AsyncGenerator 551 from typing import AsyncGenerator 553 async def f() -> AsyncGenerator[int, None]: 564 from typing import AsyncGenerator 676 from typing import AsyncGenerator, Any 689 from typing import AsyncGenerator, Any [all …]
|
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/compute/exec/ |
H A D | plan_test.cc | 223 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 246 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 293 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 417 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 682 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 704 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 770 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 906 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 996 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() 1047 AsyncGenerator<util::optional<ExecBatch>> sink_gen; in TEST() [all …]
|
H A D | test_util.h | 52 AsyncGenerator<util::optional<ExecBatch>> gen(bool parallel, bool slow) const { in gen() 56 AsyncGenerator<util::optional<ExecBatch>> gen; in gen() 85 ExecPlan* plan, AsyncGenerator<util::optional<ExecBatch>> gen);
|
/dports/devel/pytype/pytype-2021.9.9/pytype/typeshed/stdlib/ |
H A D | _collections_abc.pyi | 3 AsyncGenerator as AsyncGenerator, 34 "AsyncGenerator",
|
/dports/devel/py-mypy/mypy-0.910/mypy/typeshed/stdlib/ |
H A D | _collections_abc.pyi | 3 AsyncGenerator as AsyncGenerator, 34 "AsyncGenerator",
|
/dports/devel/py-prompt-toolkit/prompt_toolkit-3.0.23/prompt_toolkit/completion/ |
H A D | base.py | 4 from typing import AsyncGenerator, Callable, Iterable, Optional, Sequence 191 ) -> AsyncGenerator[Completion, None]: 223 ) -> AsyncGenerator[Completion, None]: 268 ) -> AsyncGenerator[Completion, None]: 306 ) -> AsyncGenerator[Completion, None]: 334 ) -> AsyncGenerator[Completion, None]:
|
/dports/textproc/p5-CSS-Sass/CSS-Sass-3.6.4/t/sass-spec/lib-js/ |
H A D | compiler.ts | 59 private readonly stdout: AsyncGenerator<string>, 60 private readonly stderr: AsyncGenerator<string>, 190 private static async *toChunks(stream: Readable): AsyncGenerator<string> { 217 generator: AsyncGenerator<string>
|
/dports/devel/folly/folly-2021.12.27.00/folly/python/test/ |
H A D | AsyncGeneratorTest.cpp | 26 coro::AsyncGenerator<int> make_generator_val() { in make_generator_val() 34 coro::AsyncGenerator<int&> make_generator_ref() { in make_generator_ref() 47 coro::AsyncGenerator<MoveOnly&&> make_generator_rref() { in make_generator_rref()
|
/dports/www/py-fastapi/fastapi-0.70.0/tests/ |
H A D | test_dependency_class.py | 1 from typing import AsyncGenerator, Generator 26 async def __call__(self, value: str) -> AsyncGenerator[str, None]: 40 async def asynchronous_gen(self, value: str) -> AsyncGenerator[str, None]:
|
/dports/devel/py-tartiflette/tartiflette-1.4.1/tartiflette/utils/ |
H A D | callables.py | 7 from typing import AsyncGenerator, Coroutine 27 def is_valid_async_generator(generator: AsyncGenerator) -> bool: argument
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/ |
H A D | Sink.h | 73 folly::coro::Task<R> sink(folly::coro::AsyncGenerator<T&&> generator) { in sink() 78 [this, &sinkError](folly::coro::AsyncGenerator<T&&> _generator) in sink() 79 -> folly::coro::AsyncGenerator< in sink() 132 folly::coro::AsyncGenerator<SinkElement&&>)>;
|