1 #include "rxcpp/rx.hpp" 2 3 #include "rxcpp/rx-test.hpp" 4 #include "catch.hpp" 5 6 SCENARIO("sequence_equal sample"){ 7 printf("//! [sequence_equal sample]\n"); 8 auto source = rxcpp::observable<>::range(1, 3); 9 auto values = source.sequence_equal(rxcpp::observable<>::range(1, 3)); 10 values. 11 subscribe( 12 [](bool v){ printf("OnNext: %s\n", v ? "true" : "false"); }, 13 [](){ printf("OnCompleted\n");} ); 14 printf("//! [sequence_equal sample]\n"); 15 } 16
