Searched refs:onnext (Results 1 – 2 of 2) sorted by relevance
48 OnNextForward() : onnext() {} in OnNextForward()49 explicit OnNextForward(onnext_t on) : onnext(std::move(on)) {} in OnNextForward()50 onnext_t onnext; member52 onnext(s, t); in operator ()()55 onnext(s, t); in operator ()()199 on_next_t onnext; member in rxcpp::observer207 , onnext(std::move(n)) in observer()214 , onnext(std::move(n)) in observer()221 , onnext(o.onnext) in observer()228 , onnext(std::move(o.onnext)) in observer()[all …]
41 OnNext onnext; member in syncwithvoid::sync_subscriber44 : onnext(on) in sync_subscriber()51 onnext(v); in on_next()66 auto onnext = [c](int){++*c;}; in __anon0164c1a70102() variable67 syncwithvoid::sync_subscriber<int, decltype(onnext)> scbr(onnext);102 OnNext onnext; member in asyncwithready::async_subscriber106 : onnext(on) in async_subscriber()117 onnext(v); in on_next()151 auto onnext = [&c](int){++*c;}; in __anon0164c1a70302() variable152 asyncwithready::async_subscriber<int, decltype(onnext)> scbr(onnext);[all …]