| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | TakeTest.kt | 18 assertEquals(3, flow.take(2).sum()) in <lambda>()
19 assertEquals(3, flow.take(Int.MAX_VALUE).sum()) in <lambda>()
20 assertEquals(1, flow.take(1).single()) in <lambda>()
21 assertEquals(2, flow.drop(1).take(1).single()) in <lambda>()
26 val sum = emptyFlow<Int>().take(10).sum() in <lambda>()
34 flow.take(-1) in testNonPositiveValues()
38 flow.take(0) in testNonPositiveValues()
55 assertEquals(1, flow.take(1).single()) in <lambda>()
69 }.take(2) in <lambda>()
95 }.take(2) in <lambda>()
[all …]
|
| /external/clang/test/Sema/ |
| D | block-args.c | 3 void take(void*);
6 take(^(int x){}); in test()
7 take(^(int x, int y){}); in test()
8 take(^(int x, int y){}); in test()
9 take(^(int x, // expected-note {{previous declaration is here}} in test()
13 take(^(int x) { return x+1; }); in test()
16 take(CP); in test()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/ |
| D | NumbersBenchmark.kt | 52 val next = source.take(1).single() in <lambda>()
75 primesFlow().take(primes).count() in <lambda>()
79 fun primesRx() = generateRxPrimes().take(primes.toLong()).count().blockingGet() in <lambda>()
83 val numbers = numbers().take(natural) in <lambda>()
95 val numbers = rxNumbers().take(natural.toLong()) in <lambda>()
109 .take(natural) in <lambda>()
117 return rxNumbers().take(natural.toLong()) in <lambda>()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | switch_on_next.cpp | 9 take(3).
13 auto values = base.switch_on_next().take(10);
24 take(3).
28 auto values = base.switch_on_next(rxcpp::observe_on_new_thread()).take(10);
|
| D | interval.cpp | 11 take(3).
24 take(3).
37 take(3).
51 take(3).
|
| D | range.cpp | 62 take(3).
66 take(3).
91 take(6).
108 take(3).
113 take(3).
143 take(6).
|
| D | replay.cpp | 11 take(5).
37 take(5).
68 take(5).
94 take(5).
125 take(5).
151 take(5).
182 take(5).
208 take(5).
|
| D | take_until.cpp | 8 auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7);
20 auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7);
34 … auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){ in __anonb9853a230502()
55 … auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){ in __anonb9853a230902()
|
| D | combine_latest.cpp | 13 take(5).
40 take(5).
60 take(5).
79 take(5).
|
| D | with_latest_from.cpp | 13 take(5).
40 take(5).
60 take(5).
79 take(5).
|
| D | window.cpp | 44 take(7).
65 take(7).
85 take(7).
122 take(7).
141 take(7).
200 take(7).
224 take(7).
|
| D | zip.cpp | 13 take(3).
40 take(3).
60 take(3).
79 take(3).
|
| D | publish.cpp | 12 take(5).
43 take(5).
74 take(5).
115 take(5).
|
| D | buffer.cpp | 50 take(7).
72 take(7).
92 take(7).
129 take(7).
148 take(7).
|
| /external/clang/test/CXX/temp/temp.param/ |
| D | p15-cxx0x.cpp | 83 typedef types<typename Take<_>::type...> take; typedef
88 template<unsigned N, typename...Ts> struct take { struct
90 …template inner<wrap<Ts>::template inner...>::take; // expected-error {{too few template arguments}}
97 using T1 = take<3, int, char, double, long>::type; // expected-note {{previous}}
104 using T2 = take<4, int, char, double, long>::type; // expected-note {{previous}}
112 using T3 = take<5, int, char, double, long>::type; // expected-note {{in instantiation of}}
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/ |
| D | get_single_element_test.py | 40 skip=[0, 5, 10], take=[1], error=[None], error_msg=[None]) +
43 take=[1],
47 take=[2],
50 def testGetSingleElement(self, skip, take, error=None, error_msg=None): argument
58 skip).map(lambda x: (x * x, make_sparse(x))).take(take)
|
| /external/eigen/unsupported/test/ |
| D | cxx11_meta.cpp | 24 using Eigen::internal::take;
164 VERIFY((is_same<typename take<0, tl>::type, type_list<>>::value)); in test_slice()
165 VERIFY((is_same<typename take<1, tl>::type, type_list<dummy_a>>::value)); in test_slice()
166 VERIFY((is_same<typename take<2, tl>::type, type_list<dummy_a, dummy_a>>::value)); in test_slice()
167 VERIFY((is_same<typename take<3, tl>::type, type_list<dummy_a, dummy_a, dummy_b>>::value)); in test_slice()
168 …VERIFY((is_same<typename take<4, tl>::type, type_list<dummy_a, dummy_a, dummy_b, dummy_b>>::value)… in test_slice()
169 …VERIFY((is_same<typename take<5, tl>::type, type_list<dummy_a, dummy_a, dummy_b, dummy_b, dummy_c>… in test_slice()
170 …VERIFY((is_same<typename take<6, tl>::type, type_list<dummy_a, dummy_a, dummy_b, dummy_b, dummy_c,… in test_slice()
172 VERIFY((is_same<typename take<0, il>::type, numeric_list<int>>::value)); in test_slice()
173 VERIFY((is_same<typename take<1, il>::type, numeric_list<int, 0>>::value)); in test_slice()
[all …]
|
| /external/rust/crates/unicode-xid/src/ |
| D | tests.rs | 21 let string = iter::repeat('a').take(4096).collect::<String>(); in cargo_is_xid_start()
32 let string = iter::repeat('a').take(4096).collect::<String>(); in stdlib_is_xid_start()
43 let string = iter::repeat('a').take(4096).collect::<String>(); in cargo_xid_continue()
54 let string = iter::repeat('a').take(4096).collect::<String>(); in stdlib_xid_continue()
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/optimization/ |
| D | inject_prefetch_test.py | 44 dataset = dataset.take(50)
56 dataset = dataset.take(5)
72 dataset = dataset.take(50)
95 dataset = dataset.take(50)
103 dataset = dataset.map(lambda x: x + 1).take(50)
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | ticket.h | 69 inline Ticket take();
75 inline void take(size_t count, const F& f);
170 Ticket Ticket::Queue::take() { in take() function
172 take(1, [&](Ticket&& ticket) { out = std::move(ticket); }); in take()
177 void Ticket::Queue::take(size_t n, const F& f) { in take() function
|
| /external/testng/src/main/java/org/testng/internal/ |
| D | PoolService.java | 48 Future<FutureType> take = m_completionService.take(); in submitTasksAndWait() local
49 result.add(take.get()); in submitTasksAndWait()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-take.hpp | 42 struct take : public operator_base<T> struct
58 take(source_type s, count_type t) in take() argument
133 auto take(AN&&... an) in take() function
148 class Take = rxo::detail::take<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Count>>,
|
| /external/e2fsprogs/tests/t_dangerous/ |
| D | expect | 39 Enabling checksums could take some time.
43 Resizing inodes could take some time.
56 Enabling checksums could take some time.
74 Resizing inodes could take some time.
78 Setting the UUID on this filesystem could take some time.
118 Setting the UUID on this filesystem could take some time.
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | take.cpp | 24 | rxo::take(2) in __anonc75d65fa0102()
86 .take(20) in __anonc75d65fa0202()
163 .take(17) in __anonc75d65fa0302()
240 .take(10) in __anonc75d65fa0402()
312 .take(20) in __anonc75d65fa0502()
389 .take(17) in __anonc75d65fa0602()
466 .take(3) in __anonc75d65fa0702()
528 .take(3) in __anonc75d65fa0802()
589 .take(3) in __anonc75d65fa0902()
|
| /external/Reactive-Extensions/RxCpp/Ix/CPP/src/cpplinq/ |
| D | linq_take.hpp | 88 const linq_take<Collection>& take in get_cursor() argument
90 -> decltype(get_cursor_(take, typename Collection::cursor::cursor_category())) in get_cursor()
92 return get_cursor_(take, typename Collection::cursor::cursor_category()); in get_cursor()
|