Home
last modified time | relevance | path

Searched refs:AsyncGenerator (Results 26 – 50 of 381) sorted by relevance

12345678910>>...16

/dports/devel/folly/folly-2021.12.27.00/folly/experimental/coro/test/
H A DMultiplexTest.cpp37 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 DDematerializeTest.cpp43 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 DAsyncGeneratorBenchmark.cpp36 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 DTransformTest.cpp48 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 DMaterializeTest.cpp43 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 DTimeoutTest.cpp167 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 DMerge.h44 AsyncGenerator<Reference, Value> merge(
46 AsyncGenerator<AsyncGenerator<Reference, Value>> sources);
H A DConcat.h53 AsyncGenerator<HReference, HValue> concat(
54 AsyncGenerator<HReference, HValue> head,
55 AsyncGenerator<TReference, TValue>... tail);
H A DDematerialize.h57 AsyncGenerator<Reference, Value> dematerialize(
58 AsyncGenerator<CallbackRecord<Reference>, CallbackRecord<Value>> source);
H A DFilter.h40 AsyncGenerator<Reference, Value> filter(
41 AsyncGenerator<Reference, Value> source, FilterFn filterFn);
H A DTransform.h53 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 Dasync_generator.h30 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 Dasync_test_util.h32 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 Dtest_client.py18 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 Dcheck-async-await.test436 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 Dplan_test.cc223 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 Dtest_util.h52 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.pyi3 AsyncGenerator as AsyncGenerator,
34 "AsyncGenerator",
/dports/devel/py-mypy/mypy-0.910/mypy/typeshed/stdlib/
H A D_collections_abc.pyi3 AsyncGenerator as AsyncGenerator,
34 "AsyncGenerator",
/dports/devel/py-prompt-toolkit/prompt_toolkit-3.0.23/prompt_toolkit/completion/
H A Dbase.py4 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 Dcompiler.ts59 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 DAsyncGeneratorTest.cpp26 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 Dtest_dependency_class.py1 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 Dcallables.py7 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 DSink.h73 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&&>)>;

12345678910>>...16