/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/stream/gen-py3/module/ |
H A D | services.pyi | 25 _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 D | async_generator.h | 70 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 D | async_generator_test.cc | 46 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 D | MergeTest.cpp | 41 []() -> 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 D | AsyncGeneratorTest.cpp | 44 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 D | FilterTest.cpp | 31 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 D | async_generator.h | 30 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 D | Multiplex.h | 70 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 D | Multiplex-inl.h | 31 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 D | Concat-inl.h | 27 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 D | AsyncGenerator.h | 134 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 D | Merge-inl.h | 40 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 D | lib.es2018.asyncgenerator.d.ts | 23 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 D | lib.es2018.asyncgenerator.d.ts | 23 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 D | lib.es2018.asyncgenerator.d.ts | 23 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 D | lib.es2018.asyncgenerator.d.ts | 23 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 D | lib.es2018.asyncgenerator.d.ts | 23 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 D | lib.es2018.asyncgenerator.d.ts | 23 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 D | lib.es2018.asyncgenerator.d.ts | 23 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 D | lib.es2018.asyncgenerator.d.ts | 23 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 D | TestSinkService.cpp | 29 [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 D | simplegenerator.h | 28 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 D | SinkServiceTest.cpp | 69 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 D | helpers.pyi | 21 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 D | TransformTest.cpp | 93 -> 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 …]
|