HomeSort by relevance Sort by last modified time
    Searched defs:as_blocking (Results 1 - 2 of 2) sorted by null

  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
rx-subscribe.hpp 129 -> decltype(std::forward<Observable>(source).as_blocking()) { function in class:rxcpp::operators::detail::blocking_factory
130 return std::forward<Observable>(source).as_blocking();
144 inline auto as_blocking()
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
rx-observable.hpp 336 source.count().as_blocking().subscribe_with_rethrow(
359 return source.sum().as_blocking().last();
380 return source.average().as_blocking().last();
401 return source.max().as_blocking().last();
422 return source.min().as_blocking().last();
588 /*! @copydoc rxcpp::operators::as_blocking
591 blocking_observable<T, this_type> as_blocking(AN**...) const { function in class:rxcpp::observable
593 static_assert(sizeof...(AN) == 0, "as_blocking() was passed too many arguments.");
    [all...]

Completed in 1030 milliseconds