Home	Sort by relevance Sort by last modified time

Full Search Definition Symbol File Path History   | | Help

    Searched refs:testable_observable (Results 1 - 7 of 7) sorted by null

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
rx-test.hpp	83 class testable_observable class in namespace:rxcpp::test 95 explicit testable_observable(test_subject ts) function in class:rxcpp::test::testable_observable 120 auto operator >> (const rxcpp::test::testable_observable<T>& source, OperatorFactory&& of) 130 auto operator | (const rxcpp::test::testable_observable<T>& source, OperatorFactory&& of)
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
defer.cpp	11 rxu::detail::maybe<rx::test::testable_observable<long>> xs;
scope.cpp	9 rxu::detail::maybe<rx::test::testable_observable<int>> xs; 70 rxu::detail::maybe<rx::test::testable_observable<int>> xs; 134 rxu::detail::maybe<rx::test::testable_observable<int>> xs; 201 rxu::detail::maybe<rx::test::testable_observable<int>> xs; 266 rxu::detail::maybe<rx::test::testable_observable<int>> xs;
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
rx-test.hpp	153 rxt::testable_observable<T> make_hot_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::detail::notification_base<T>>>> messages) const; 156 rxt::testable_observable<T> make_cold_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::detail::notification_base<T>>>> messages) const; 275 rxt::testable_observable<T> test_type::make_cold_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::detail::notification_base<T>>>> messages) const 278 return rxt::testable_observable<T>(co); 341 rxt::testable_observable<T> test_type::make_hot_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::detail::notification_base<T>>>> messages) const 345 return rxt::testable_observable<T>(shared); 569 rxt::testable_observable<T> make_hot_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::detail::notification_base<T>>>> messages) const{ 586 rxt::testable_observable<T> make_cold_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::detail::notification_base<T>>>> messages) const {
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
combine_latest.cpp	279 std::vector<rxcpp::test::testable_observable<int>> n; 312 std::for_each(n.begin(), n.end(), [&](rxcpp::test::testable_observable<int> &s){ 332 std::vector<rxcpp::test::testable_observable<int>> e; 369 std::for_each(e.begin(), e.end(), [&](rxcpp::test::testable_observable<int> &s){     [all...]
with_latest_from.cpp	278 std::vector<rxcpp::test::testable_observable<int>> n; 311 std::for_each(n.begin(), n.end(), [&](rxcpp::test::testable_observable<int> &s){ 331 std::vector<rxcpp::test::testable_observable<int>> e; 368 std::for_each(e.begin(), e.end(), [&](rxcpp::test::testable_observable<int> &s){     [all...]
zip.cpp	67 std::vector<rxcpp::test::testable_observable<int>> n; 100 std::for_each(n.begin(), n.end(), [&](rxcpp::test::testable_observable<int> &s){ 291 std::vector<rxcpp::test::testable_observable<int>> e; 328 std::for_each(e.begin(), e.end(), [&](rxcpp::test::testable_observable<int> &s){     [all...]

Completed in 585 milliseconds