Home
last modified time | relevance | path

Searched refs:asyncUnsubscriptions (Results 1 – 1 of 1) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/
Dsubject.cpp314 std::atomic<int> asyncUnsubscriptions{0}; variable
326 f[i] = std::async([sub, o, &asyncUnsubscriptions]() { in __anon6a6aec1e0d02()
332 .finally([&asyncUnsubscriptions](){ in __anon6a6aec1e0d02()
333 ++asyncUnsubscriptions;}) in __anon6a6aec1e0d02()
365 std::cout << std::setw(4) << asyncUnsubscriptions << " async, ";
387 std::atomic<int> asyncUnsubscriptions{0}; variable
399 f[i] = std::async([sub, o, &asyncUnsubscriptions]() { in __anon6a6aec1e1402()
404 .finally([&asyncUnsubscriptions](){ in __anon6a6aec1e1402()
405 ++asyncUnsubscriptions;}) in __anon6a6aec1e1402()
438 std::cout << std::setw(4) << asyncUnsubscriptions << " async, ";