Lines Matching refs:onnext
41 OnNext onnext; member in syncwithvoid::sync_subscriber
44 : onnext(on) in sync_subscriber()
51 onnext(v); in on_next()
66 auto onnext = [c](int){++*c;}; in __anon2b91aec50102() variable
67 syncwithvoid::sync_subscriber<int, decltype(onnext)> scbr(onnext);
102 OnNext onnext; member in asyncwithready::async_subscriber
106 : onnext(on) in async_subscriber()
117 onnext(v); in on_next()
151 auto onnext = [&c](int){++*c;}; in __anon2b91aec50302() variable
152 asyncwithready::async_subscriber<int, decltype(onnext)> scbr(onnext);
179 OnNext onnext; member in asyncwithfuture::async_subscriber
182 : onnext(on) in async_subscriber()
191 onnext(v); return ready.get_future();} in on_next()
205 auto onnext = [&c](int){++*c;}; in __anon2b91aec50502() variable
206 asyncwithfuture::async_subscriber<int, decltype(onnext)> scbr(onnext);