Home
last modified time | relevance | path

Searched refs:AsyncGenerator (Results 1 – 25 of 381) sorted by relevance

12345678910>>...16

/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/stream/gen-py3/module/
H A Dservices.pyi25 _typing.AsyncGenerator[int, None],
35 …) -> _typing.Union[_typing.Awaitable[_typing.AsyncGenerator[int, None]],_typing.AsyncGenerator[int…
39 _typing.AsyncGenerator[int, None],
48 …) -> _typing.Union[_typing.Awaitable[_typing.AsyncGenerator[int, None]],_typing.AsyncGenerator[int…
52 _typing.AsyncGenerator[int, None],
61 …) -> _typing.Union[_typing.Awaitable[_typing.AsyncGenerator[int, None]],_typing.AsyncGenerator[int…
65 _typing.AsyncGenerator[int, None],
74 ….Tuple[int, _typing.Union[_typing.Awaitable[_typing.AsyncGenerator[int, None]],_typing.AsyncGenera…
78 _typing.AsyncGenerator[int, None],
88 …) -> _typing.Union[_typing.Awaitable[_typing.AsyncGenerator[int, None]],_typing.AsyncGenerator[int…
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/util/
H A Dasync_generator.h70 static AsyncGenerator<T> End() { return AsyncGenerator<T>(); }
546 AsyncGenerator<V> MakeTransformedGenerator(AsyncGenerator<T> generator,
696 AsyncGenerator<T> MakeFromFuture(Future<AsyncGenerator<T>> future) {
994 explicit MergedGenerator(AsyncGenerator<AsyncGenerator<T>> source,
1061 AsyncGenerator<AsyncGenerator<T>> source;
1183 AsyncGenerator<T> MakeMergedGenerator(AsyncGenerator<AsyncGenerator<T>> source,
1190 AsyncGenerator<AsyncGenerator<T>> source, int max_subscriptions) {
1200 AsyncGenerator<AsyncGenerator<T>> sub_readahead =
1217 AsyncGenerator<T> MakeConcatenatedGenerator(AsyncGenerator<AsyncGenerator<T>> source) {
1325 AsyncGenerator<T> MakeTransferredGenerator(AsyncGenerator<T> source,
[all …]
H A Dasync_generator_test.cc46 AsyncGenerator<T> FailsAt(AsyncGenerator<T> src, int failing_index) { in FailsAt()
58 AsyncGenerator<T> SlowdownABit(AsyncGenerator<T> source) { in SlowdownABit()
65 AsyncGenerator<T> MakeJittery(AsyncGenerator<T> source) { in MakeJittery()
153 AsyncGenerator<T> source;
575 auto merged = MakeMergedGenerator(AsyncGenerator<AsyncGenerator<TestInt>>(tracker), 2); in TEST_P()
622 AsyncGenerator<AsyncGenerator<TestInt>> source_gen = AsyncVectorIt(sources); in TEST_P()
656 auto merged = MakeMergedGenerator(AsyncGenerator<AsyncGenerator<TestInt>>(sources), 1); in TEST_P()
770 static_cast<AsyncGenerator<AsyncGenerator<TestInt>>>(tracked_source_), 4)); in TEST_F()
820 static_cast<AsyncGenerator<AsyncGenerator<TestInt>>>(tracked_source_), 4)); in TEST_F()
839 static_cast<AsyncGenerator<AsyncGenerator<TestInt>>>(tracked_source_), 4)); in TEST_F()
[all …]
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/coro/test/
H A DMergeTest.cpp41 []() -> AsyncGenerator<AsyncGenerator<int>> { in TEST_F()
42 auto makeGenerator = [](int start, int count) -> AsyncGenerator<int> { in TEST_F()
72 co_invoke([&]() -> AsyncGenerator<AsyncGenerator<int>> { in TEST_F()
73 auto makeGenerator = [&]() -> AsyncGenerator<int> { in TEST_F()
107 []() -> AsyncGenerator<AsyncGenerator<std::vector<int>&&>> { in TEST_F()
108 auto makeStreamOfVectors = []() -> AsyncGenerator<std::vector<int>&&> { in TEST_F()
132 []() -> AsyncGenerator<AsyncGenerator<std::vector<int>&>> { in TEST_F()
133 auto makeStreamOfVectors = []() -> AsyncGenerator<std::vector<int>&> { in TEST_F()
170 folly::coro::AsyncGenerator<Ref, Value> neverStream() { in neverStream()
189 neverStream<AsyncGenerator<int>>()); in TEST_F()
[all …]
H A DAsyncGeneratorTest.cpp44 folly::coro::AsyncGenerator<int> g; in TEST_F()
406 folly::coro::AsyncGenerator<Ref, Value> neverStream() { in neverStream()
452 auto gen = []() -> folly::coro::AsyncGenerator<int> { in TEST_F()
485 TEST(AsyncGenerator, YieldCoError) { in TEST() argument
507 TEST(AsyncGenerator, YieldCoResult) { in TEST() argument
538 TEST(AsyncGenerator, CoResultProxyExample) { in TEST() argument
541 -> folly::coro::AsyncGenerator<int> { in TEST()
562 gen = []() -> folly::coro::AsyncGenerator<int> { in TEST()
600 TEST(AsyncGenerator, SafePoint) { in TEST() argument
632 TEST(AsyncGenerator, CoAwaitNothrow) { in TEST() argument
[all …]
H A DFilterTest.cpp31 const auto allNumbers = []() -> AsyncGenerator<int> { in TEST_F()
47 const auto emptyStream = []() -> AsyncGenerator<int> { co_return; }; in TEST_F()
54 const auto nonEmptyStream = []() -> AsyncGenerator<int> { in TEST_F()
67 const auto throwingStream = []() -> AsyncGenerator<int> { in TEST_F()
83 auto nonThrowingStream = []() -> AsyncGenerator<int> { in TEST_F()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/util/
H A Dasync_generator.h30 using AsyncGenerator = std::function<Future<T>()>; variable
35 Future<> VisitAsyncGenerator(AsyncGenerator<T> generator, in VisitAsyncGenerator()
61 AsyncGenerator<T> generator; in VisitAsyncGenerator()
84 AsyncGenerator<T> generator; in CollectAsyncGenerator()
162 AsyncGenerator<T> generator_;
222 AsyncGenerator<T> source_generator_;
239 AsyncGenerator<T> MakeReadaheadGenerator(AsyncGenerator<T> source_generator, in MakeReadaheadGenerator()
253 AsyncGenerator<V> MakeAsyncGenerator(AsyncGenerator<T> generator, in MakeAsyncGenerator()
270 AsyncGenerator<T> source_;
286 AsyncGenerator<T> MakeTransferredGenerator(AsyncGenerator<T> source, in MakeTransferredGenerator()
[all …]
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/coro/
H A DMultiplex.h70 invoke_result_t<SelectIdFn&, const AsyncGenerator<Reference, Value>&>>>
71 AsyncGenerator<
76 AsyncGenerator<AsyncGenerator<Reference, Value>>&& sources,
80 AsyncGenerator<
85 AsyncGenerator<AsyncGenerator<Reference, Value>>&& sources);
H A DMultiplex-inl.h31 AsyncGenerator<
36 AsyncGenerator<AsyncGenerator<Reference, Value>>&& sources, in multiplex()
46 AsyncGenerator<Reference, Value>&& item) mutable { in multiplex()
65 AsyncGenerator<
70 AsyncGenerator<AsyncGenerator<Reference, Value>>&& sources) { in multiplex()
H A DConcat-inl.h27 AsyncGenerator<HReference, HValue> concat( in concat()
28 AsyncGenerator<HReference, HValue> head, in concat()
29 AsyncGenerator<TReference, TValue>... tail) { in concat()
31 using list = AsyncGenerator<HReference, HValue>[]; in concat()
H A DAsyncGenerator.h134 class FOLLY_NODISCARD AsyncGenerator {
151 AsyncGenerator() noexcept : coro_() {} in AsyncGenerator() function
153 AsyncGenerator(AsyncGenerator&& other) noexcept in AsyncGenerator() function
156 ~AsyncGenerator() { in ~AsyncGenerator()
162 AsyncGenerator& operator=(AsyncGenerator&& other) noexcept {
337 friend AsyncGenerator;
350 friend AsyncGenerator tag_invoke( in tag_invoke()
361 explicit AsyncGenerator(coroutine_handle<promise_type> coro) noexcept in AsyncGenerator() function
417 AsyncGenerator<Reference, Value> get_return_object() noexcept { in get_return_object()
418 return AsyncGenerator<Reference, Value>{ in get_return_object()
[all …]
H A DMerge-inl.h40 AsyncGenerator<Reference, Value> merge( in merge()
42 AsyncGenerator<AsyncGenerator<Reference, Value>> sources) { in merge()
57 AsyncGenerator<AsyncGenerator<Reference, Value>> sources_) in merge()
60 AsyncGenerator<Reference, Value> generator) in merge()
/dports/devel/jetbrains-webstorm/WebStorm-213.6461.79/plugins/JavaScriptLanguage/jsLanguageServicesImpl/external/
H A Dlib.es2018.asyncgenerator.d.ts23 interface AsyncGenerator<T = unknown, TReturn = any, TNext = unknown> extends AsyncIterator<T, TRet… interface
28 [Symbol.asyncIterator](): AsyncGenerator<T, TReturn, TNext>;
36 new (...args: any[]): AsyncGenerator;
41 (...args: any[]): AsyncGenerator;
53 readonly prototype: AsyncGenerator;
/dports/devel/jetbrains-goland/GoLand-2019.3.1/plugins/JavaScriptLanguage/jsLanguageServicesImpl/external/
H A Dlib.es2018.asyncgenerator.d.ts23 interface AsyncGenerator<T = unknown, TReturn = any, TNext = unknown> extends AsyncIterator<T, TRet… interface
28 [Symbol.asyncIterator](): AsyncGenerator<T, TReturn, TNext>;
36 new (...args: any[]): AsyncGenerator;
41 (...args: any[]): AsyncGenerator;
53 readonly prototype: AsyncGenerator;
/dports/java/netbeans/netbeans/webcommon/typescript-lsp/node_modules/typescript/lib/
H A Dlib.es2018.asyncgenerator.d.ts23 interface AsyncGenerator<T = unknown, TReturn = any, TNext = unknown> extends AsyncIterator<T, TRet… interface
28 [Symbol.asyncIterator](): AsyncGenerator<T, TReturn, TNext>;
36 new (...args: any[]): AsyncGenerator;
41 (...args: any[]): AsyncGenerator;
53 readonly prototype: AsyncGenerator;
/dports/devel/jetbrains-phpstorm/PhpStorm-213.6461.83/plugins/JavaScriptLanguage/jsLanguageServicesImpl/external/
H A Dlib.es2018.asyncgenerator.d.ts23 interface AsyncGenerator<T = unknown, TReturn = any, TNext = unknown> extends AsyncIterator<T, TRet… interface
28 [Symbol.asyncIterator](): AsyncGenerator<T, TReturn, TNext>;
36 new (...args: any[]): AsyncGenerator;
41 (...args: any[]): AsyncGenerator;
53 readonly prototype: AsyncGenerator;
/dports/www/py-bokeh/bokeh-2.3.3/bokeh/server/static/lib/
H A Dlib.es2018.asyncgenerator.d.ts23 interface AsyncGenerator<T = unknown, TReturn = any, TNext = unknown> extends AsyncIterator<T, TRet… interface
28 [Symbol.asyncIterator](): AsyncGenerator<T, TReturn, TNext>;
36 new (...args: any[]): AsyncGenerator;
41 (...args: any[]): AsyncGenerator;
53 readonly prototype: AsyncGenerator;
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/devtools-frontend/src/node_modules/typescript/lib/
H A Dlib.es2018.asyncgenerator.d.ts23 interface AsyncGenerator<T = unknown, TReturn = any, TNext = unknown> extends AsyncIterator<T, TRet… interface
28 [Symbol.asyncIterator](): AsyncGenerator<T, TReturn, TNext>;
36 new (...args: any[]): AsyncGenerator;
41 (...args: any[]): AsyncGenerator;
53 readonly prototype: AsyncGenerator;
/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/JavaScriptLanguage/jsLanguageServicesImpl/external/
H A Dlib.es2018.asyncgenerator.d.ts23 interface AsyncGenerator<T = unknown, TReturn = any, TNext = unknown> extends AsyncIterator<T, TRet… interface
28 [Symbol.asyncIterator](): AsyncGenerator<T, TReturn, TNext>;
36 new (...args: any[]): AsyncGenerator;
41 (...args: any[]): AsyncGenerator;
53 readonly prototype: AsyncGenerator;
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/node_modules/typescript/lib/
H A Dlib.es2018.asyncgenerator.d.ts23 interface AsyncGenerator<T = unknown, TReturn = any, TNext = unknown> extends AsyncIterator<T, TRet… interface
28 [Symbol.asyncIterator](): AsyncGenerator<T, TReturn, TNext>;
36 new (...args: any[]): AsyncGenerator;
41 (...args: any[]): AsyncGenerator;
53 readonly prototype: AsyncGenerator;
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/tests/util/
H A DTestSinkService.cpp29 [from, to](folly::coro::AsyncGenerator<int32_t&&> gen) in range()
45 [from](folly::coro::AsyncGenerator<int32_t&&> gen) in rangeThrow()
67 [from](folly::coro::AsyncGenerator<int32_t&&> gen) in rangeFinalResponseThrow()
86 [from, early](folly::coro::AsyncGenerator<int32_t&&> gen) in rangeEarlyResponse()
107 folly::coro::AsyncGenerator<int32_t&&> gen) mutable in unSubscribedSink()
123 folly::coro::AsyncGenerator<int32_t&&> gen) mutable in semifuture_unSubscribedSinkSlowReturn()
147 [](folly::coro::AsyncGenerator<int32_t&&> gen) in rangeChunkTimeout()
166 [](folly::coro::AsyncGenerator<int32_t&&> gen) in sinkThrow()
187 [](folly::coro::AsyncGenerator<int32_t&&>) -> folly::coro::Task<bool> { in sinkFinalThrow()
236 [from, to, cancelAt](folly::coro::AsyncGenerator<int32_t&&> gen) in rangeCancelAt()
[all …]
/dports/devel/folly/folly-2021.12.27.00/folly/python/test/
H A Dsimplegenerator.h28 coro::AsyncGenerator<int> make_generator_empty() { in make_generator_empty()
29 coro::AsyncGenerator<int> g; in make_generator_empty()
33 coro::AsyncGenerator<int> make_generator() { in make_generator()
42 coro::AsyncGenerator<int> make_generator_error() { in make_generator_error()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/tests/
H A DSinkServiceTest.cpp69 co_await sink.sink([]() -> folly::coro::AsyncGenerator<int&&> { in TEST_F()
83 co_await sink.sink([]() -> folly::coro::AsyncGenerator<int&&> { in TEST_F()
99 co_await sink.sink([]() -> folly::coro::AsyncGenerator<int&&> { in TEST_F()
124 co_await sink.sink([]() -> folly::coro::AsyncGenerator<int&&> { in TEST_F()
143 co_await sink.sink([]() -> folly::coro::AsyncGenerator<int&&> { in TEST_F()
316 [s]() -> folly::coro::AsyncGenerator<folly::IOBuf&&> { in TEST_F()
334 [s]() -> folly::coro::AsyncGenerator<folly::IOBuf&&> { in TEST_F()
352 [s]() -> folly::coro::AsyncGenerator<folly::IOBuf&&> { in TEST_F()
434 sink.sink([]() -> folly::coro::AsyncGenerator<int&&> { in TEST_F()
473 [s]() -> folly::coro::AsyncGenerator<folly::IOBuf&&> { in TEST_F()
[all …]
/dports/textproc/py-elasticsearch/elasticsearch-7.15.2/elasticsearch/_async/
H A Dhelpers.pyi21 AsyncGenerator,
44 ) -> AsyncGenerator[Any, None]: ...
54 ) -> AsyncGenerator[Tuple[bool, Any], None]: ...
55 def aiter(x: Union[Iterable[T], AsyncIterable[T]]) -> AsyncGenerator[T, None]: ...
58 ) -> AsyncGenerator[Tuple[T, ...], None]: ...
74 ) -> AsyncGenerator[Tuple[bool, Any], None]: ...
94 ) -> AsyncGenerator[int, None]: ...
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/channels/test/
H A DTransformTest.cpp93 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
123 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
153 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
185 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
212 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
240 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
269 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
296 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
358 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
372 -> folly::coro::AsyncGenerator<std::string&&> { in TEST_F()
[all …]

12345678910>>...16