Home
last modified time | relevance | path

Searched refs:as_blocking (Results 1 – 25 of 36) sorted by relevance

12

/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Dblocking_observable.cpp8 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
16 auto values = rxcpp::observable<>::empty<int>().as_blocking();
29 as_blocking();
41 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
49 auto values = rxcpp::observable<>::empty<int>().as_blocking();
63 as_blocking();
75 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
85 as_blocking();
97 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
105 auto values = rxcpp::observable<>::empty<int>().as_blocking();
[all …]
Dreplay.cpp24 values.as_blocking().subscribe( in __anon3e0ec51c0302()
60 values.as_blocking().subscribe();
81 values.as_blocking().subscribe( in __anon3e0ec51c0f02()
117 values.as_blocking().subscribe();
138 values.as_blocking().subscribe( in __anon3e0ec51c1b02()
174 values.as_blocking().subscribe();
195 values.as_blocking().subscribe( in __anon3e0ec51c2702()
231 values.as_blocking().subscribe();
Drange.cpp25 as_blocking().
44 as_blocking().
92 as_blocking().
119 as_blocking().
145 as_blocking().
Dpublish.cpp36 values.as_blocking().subscribe();
67 values.as_blocking().subscribe();
98 values.as_blocking().subscribe();
Dtimer.cpp34 as_blocking().
47 as_blocking().
Dconcat.cpp40 as_blocking().
55 as_blocking().
Dtake_until.cpp44 as_blocking().
62 as_blocking().
Dwindow.cpp47 as_blocking().
125 as_blocking().
164 as_blocking().
208 as_blocking().
Dbuffer.cpp53 as_blocking().
132 as_blocking().
171 as_blocking().
Dcombine_latest.cpp41 as_blocking().
80 as_blocking().
Damb.cpp52 as_blocking().
78 as_blocking().
Dmerge.cpp52 as_blocking().
78 as_blocking().
Dwith_latest_from.cpp41 as_blocking().
80 as_blocking().
Dzip.cpp41 as_blocking().
80 as_blocking().
Dmerge_delay_error.cpp61 as_blocking().
92 as_blocking().
Djust.cpp20 as_blocking().
Dobserve_on.cpp18 as_blocking().
Dsubscribe_on.cpp18 as_blocking().
Diterate.cpp22 as_blocking().
Dempty.cpp20 as_blocking().
Dfrom.cpp26 as_blocking().
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-subscribe.hpp129 -> decltype(std::forward<Observable>(source).as_blocking()) { in operator ()()
130 return std::forward<Observable>(source).as_blocking(); in operator ()()
144 inline auto as_blocking() in as_blocking() function
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dconcat.cpp25 .as_blocking()
53 .as_blocking()
81 .as_blocking()
Dmerge.cpp26 .as_blocking()
54 .as_blocking()
82 .as_blocking()
Dsubscribe_on.cpp39 .as_blocking()
80 as_blocking().

12