Searched refs:completionstate (Results 1 – 1 of 1) sorted by relevance
131 …auto completionstate = std::make_shared<std::tuple<bool, long, rx::subscriber<int>>>(false, 0, std… in __anon1ab139c80a02() local132 std::get<2>(*completionstate).add([=](){ in __anon1ab139c80a02()133 … if (std::get<1>(*completionstate) != values || !std::get<0>(*completionstate)) { in __anon1ab139c80a02()139 std::get<2>(*completionstate), in __anon1ab139c80a02()141 ++std::get<1>(*completionstate); in __anon1ab139c80a02()142 std::get<2>(*completionstate).on_next(n); in __anon1ab139c80a02()148 if (std::get<1>(*completionstate) != values) { in __anon1ab139c80a02()151 std::get<0>(*completionstate) = true; in __anon1ab139c80a02()152 std::get<2>(*completionstate).on_completed(); in __anon1ab139c80a02()240 …auto completionstate = std::make_shared<std::tuple<bool, long, rx::subscriber<int>>>(false, 0, std… in __anon1ab139c81602() local[all …]