Lines Matching defs:source
52 void construct(SO&& source, rxs::tag_source&&) {
53 rxu::decay_t<SO> so = std::forward<SO>(source);
101 template<class T, class Source>
102 observable<T> make_observable_dynamic(Source&& s) {
103 return observable<T>(dynamic_observable<T>(std::forward<Source>(s)));
163 \brief a source of values whose methods block until all values have been emitted. subscribe or use one of the operator methods that reduce the values emitted to a single value.
172 static auto blocking_subscribe(const Obsvbl& source, bool do_rethrow, ArgN&&... an)
203 source.subscribe(std::move(scbr));
216 observable_type source;
220 blocking_observable(observable_type s) : source(std::move(s)) {}
240 return blocking_subscribe(source, false, std::forward<ArgN>(an)...);
246 /// \note If the source observable calls on_error, the raised exception is rethrown by this method.
248 /// \note If the source observable calls on_error, the `on_error` method on the subscriber will not be called.
265 return blocking_subscribe(source, true, std::forward<ArgN>(an)...);
272 \note If the source observable calls on_error, the raised exception is rethrown by this method.
275 When the source observable emits at least one item:
279 When the source observable is empty:
300 \note If the source observable calls on_error, the raised exception is rethrown by this method.
303 When the source observable emits at least one item:
307 When the source observable is empty:
330 When the source observable calls on_error:
336 source.count().as_blocking().subscribe_with_rethrow(
346 When the source observable emits at least one item:
350 When the source observable is empty:
354 When the source observable calls on_error:
359 return source.sum().as_blocking().last();
367 When the source observable emits at least one item:
371 When the source observable is empty:
375 When the source observable calls on_error:
380 return source.average().as_blocking().last();
388 When the source observable emits at least one item:
392 When the source observable is empty:
396 When the source observable calls on_error:
401 return source.max().as_blocking().last();
409 When the source observable emits at least one item:
413 When the source observable is empty:
417 When the source observable calls on_error:
422 return source.min().as_blocking().last();
467 \brief a source of values. subscribe or use one of the operator methods that return a new observable, which uses this observable as a source.
532 static_assert(rxo::is_operator<source_operator_type>::value || rxs::is_source<source_operator_type>::value, "observable must wrap an operator or source");
1792 auto operator >> (const rxcpp::observable<T, SourceOperator>& source, OperatorFactory&& of)
1793 -> decltype(source.op(std::forward<OperatorFactory>(of))) {
1794 return source.op(std::forward<OperatorFactory>(of));
1802 auto operator | (const rxcpp::observable<T, SourceOperator>& source, OperatorFactory&& of)
1803 -> decltype(source.op(std::forward<OperatorFactory>(of))) {
1804 return source.op(std::forward<OperatorFactory>(of));
