/external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
D | subject.cpp | 29 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 30 … << " subscribed, " << c << " on_next calls, " << msElapsed.count() << "ms elapsed " << c / (msEla… 72 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 73 …<< " subscribed, " << *c << " on_next calls, " << msElapsed.count() << "ms elapsed " << *c / (msEl… 166 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 167 …<< " subscribed, " << *c << " on_next calls, " << msElapsed.count() << "ms elapsed " << *c / (msEl… 214 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 215 …<< " subscribed, " << *c << " on_next calls, " << msElapsed.count() << "ms elapsed " << *c / (msEl… 241 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 242 … << " subscribed, " << c << " on_next calls, " << msElapsed.count() << "ms elapsed " << c / (msEla… [all …]
|
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
D | subscription.cpp | 61 auto msElapsed = duration_cast<milliseconds>(finish-start); in __anon442cb92f0302() local 62 … << " subscribed, " << c << " on_next calls, " << msElapsed.count() << "ms elapsed, " << c / (msEl… in __anon442cb92f0302() 99 auto msElapsed = duration_cast<milliseconds>(finish-start); in __anon442cb92f0702() local 100 … << " subscribed, " << c << " on_next calls, " << msElapsed.count() << "ms elapsed, " << c / (msEl… in __anon442cb92f0702() 208 auto msElapsed = duration_cast<milliseconds>(finish-start); in __anon442cb92f0a02() local 209 … << " subscribed, " << v << " on_next calls, " << msElapsed.count() << "ms elapsed, " << v / (msEl… in __anon442cb92f0a02() 314 auto msElapsed = duration_cast<milliseconds>(finish-start); in __anon442cb92f1602() local 315 … << " subscribed, " << v << " on_next calls, " << msElapsed.count() << "ms elapsed, " << v / (msEl… in __anon442cb92f1602()
|
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
D | subscribe_on.cpp | 43 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 45 … << " subscribed, " << c << " on_next calls, " << msElapsed.count() << "ms elapsed, " << c / (msEl… 84 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 86 … << " subscribed, " << c << " on_next calls, " << msElapsed.count() << "ms elapsed, " << c / (msEl…
|
D | concat_map.cpp | 48 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 50 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla… 97 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 99 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla… 146 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 148 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla… 195 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 197 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla…
|
D | concat.cpp | 29 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 31 …"concat sync ranges : " << n << " subscribed, " << c << " emitted, " << msElapsed.count() << "ms e… 57 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 59 …t observe_on ranges : " << n << " subscribed, " << c << " emitted, " << msElapsed.count() << "ms e… 85 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 87 …oncat serial ranges : " << n << " subscribed, " << c << " emitted, " << msElapsed.count() << "ms e…
|
D | flat_map.cpp | 40 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 42 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla… 84 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 86 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla… 133 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 135 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla… 181 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 183 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla… 229 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 231 …< c << " filtered to, " << ct << " triplets, " << msElapsed.count() << "ms elapsed " << c / (msEla…
|
D | merge.cpp | 30 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 32 … "merge sync ranges : " << n << " subscribed, " << c << " emitted, " << msElapsed.count() << "ms e… 58 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 60 …e observe_on ranges : " << n << " subscribed, " << c << " emitted, " << msElapsed.count() << "ms e… 86 auto msElapsed = duration_cast<milliseconds>(finish.time_since_epoch()) - variable 88 …merge serial ranges : " << n << " subscribed, " << c << " emitted, " << msElapsed.count() << "ms e…
|
D | group_by.cpp | 89 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 90 …tition the work : " << c << " calls to pi(), " << msElapsed.count() << "ms elapsed, " << c / (msEl… 156 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 157 …tition the work : " << c << " calls to pi(), " << msElapsed.count() << "ms elapsed, " << c / (msEl…
|
D | observe_on.cpp | 45 auto msElapsed = duration_cast<milliseconds>(finish-start); variable 46 …read : " << (*c) << " on_next calls, " << msElapsed.count() << "ms elapsed, int-per-second " << *c…
|