HomeSort by relevance Sort by last modified time
    Searched refs:merge_delay_error (Results 1 - 5 of 5) sorted by null

  /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
composite_exception.cpp 13 auto values = o1.merge_delay_error(o2, o3);
merge_delay_error.cpp 9 SCENARIO("merge_delay_error sample"){
10 printf("//! [merge_delay_error sample]\n");
14 auto values = o1.merge_delay_error(o2, o3);
20 printf("//! [merge_delay_error sample]\n");
23 SCENARIO("implicit merge_delay_error sample"){
24 printf("//! [implicit merge_delay_error sample]\n");
35 printf("//! [implicit merge_delay_error sample]\n");
40 SCENARIO("threaded merge_delay_error sample"){
41 printf("//! [threaded merge_delay_error sample]\n");
67 printf("//! [threaded merge_delay_error sample]\n")
    [all...]
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
rx-merge_delay_error.hpp 5 /*! \file rx-merge_delay_error.hpp
28 \snippet merge_delay_error.cpp threaded implicit merge sample
32 \snippet merge_delay_error.cpp implicit merge sample
36 \snippet merge_delay_error.cpp merge sample
40 \snippet merge_delay_error.cpp threaded merge sample
58 struct merge_delay_error struct in namespace:rxcpp::operators::detail
64 typedef merge_delay_error<T, Observable, Coordination> this_type;
87 merge_delay_error(const source_type& o, coordination_type sf) function in struct:rxcpp::operators::detail::merge_delay_error
230 auto merge_delay_error(AN&&... an)
244 class Merge = rxo::detail::merge_delay_error<SourceValue, rxu::decay_t<Observable>, identity_one_worker>
    [all...]
  /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
merge_delay_error.cpp 3 #include <rxcpp/operators/rx-merge_delay_error.hpp>
6 //merge_delay_error must work the very same way as `merge()` except the error handling
8 SCENARIO("merge_delay_error completes", "[merge][join][operators]"){
54 | rxo::merge_delay_error()
118 SCENARIO("variadic merge_delay_error completes with error", "[merge][join][operators]"){
139 on.error(40, std::runtime_error("merge_delay_error on_error from ys2")),
158 .merge_delay_error(ys2, ys3);
212 SCENARIO("variadic merge_delay_error completes with 2 errors", "[merge][join][operators]"){
225 on.error(220, std::runtime_error("merge_delay_error on_error from ys1")),
234 on.error(40, std::runtime_error("merge_delay_error on_error from ys2"))
    [all...]
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
rx-observable.hpp     [all...]

Completed in 509 milliseconds