Lines Matching refs:dob
64 auto dob = rx::make_observer_dynamic<int>(emptyNext); variable
69 REQUIRE(rx::is_observer<decltype(dob)>::value);
107 auto dob = rx::make_subscriber<int>(rx::make_observer_dynamic<int>(next, error, completed)); variable
120 REQUIRE(dob.is_subscribed());
128 dob.on_next(1);
136 dob.on_next(1);
137 REQUIRE(dob.is_subscribed());
146 dob.on_error(rxu::current_exception());
154 dob.on_error(rxu::current_exception());
155 REQUIRE(!dob.is_subscribed());
164 dob.on_completed();
172 dob.on_completed();
173 REQUIRE(!dob.is_subscribed());