RxCpp
The Reactive Extensions for Native (RxCpp) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in both C and C++.
rx-sources.hpp
Go to the documentation of this file.
1 
2 // Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
3 
4 #pragma once
5 
6 #if !defined(RXCPP_RX_SOURCES_HPP)
7 #define RXCPP_RX_SOURCES_HPP
8 
9 #include "rx-includes.hpp"
10 
11 namespace rxcpp {
12 
13 namespace sources {
14 
15 struct tag_source {};
16 template<class T>
18 {
19  typedef T value_type;
21 };
22 template<class T>
23 class is_source
24 {
25  template<class C>
26  static typename C::source_tag* check(int);
27  template<class C>
28  static void check(...);
29 public:
30  static const bool value = std::is_convertible<decltype(check<rxu::decay_t<T>>(0)), tag_source*>::value;
31 };
32 
33 }
34 namespace rxs=sources;
35 
36 }
37 
38 #include "sources/rx-create.hpp"
39 #include "sources/rx-range.hpp"
40 #include "sources/rx-iterate.hpp"
41 #include "sources/rx-interval.hpp"
42 #include "sources/rx-empty.hpp"
43 #include "sources/rx-defer.hpp"
44 #include "sources/rx-never.hpp"
45 #include "sources/rx-error.hpp"
46 #include "sources/rx-scope.hpp"
47 #include "sources/rx-timer.hpp"
48 
49 #endif
rx-includes.hpp
rxcpp::sources::source_base
Definition: rx-sources.hpp:17
rxcpp::util::decay_t
typename std::decay< T >::type decay_t
Definition: rx-util.hpp:48
rxcpp::sources::is_source
Definition: rx-sources.hpp:23
rx-error.hpp
Returns an observable that sends no items to observer and immediately generates an error,...
rx-empty.hpp
Returns an observable that sends no items to observer and immediately completes, on the specified sch...
rxcpp::sources::tag_source
Definition: rx-sources.hpp:15
rx-range.hpp
Returns an observable that sends values in the range first-last by adding step to the previous value....
rx-scope.hpp
Returns an observable that makes an observable by the specified observable factory using the resource...
rx-never.hpp
Returns an observable that never sends any items or notifications to observer.
rx-create.hpp
Returns an observable that executes the specified function when a subscriber subscribes to it.
rxcpp::sources::source_base::value_type
T value_type
Definition: rx-sources.hpp:19
rx-interval.hpp
Returns an observable that emits a sequential integer every specified time interval,...
rx-iterate.hpp
Returns an observable that sends each value in the collection, on the specified scheduler.
rx-timer.hpp
Returns an observable that emits an integer at the specified time point.
rxcpp::sources::source_base::source_tag
tag_source source_tag
Definition: rx-sources.hpp:20
rx-defer.hpp
Returns an observable that calls the specified observable factory to create an observable for each ne...
rxcpp
Definition: rx-all.hpp:26
rxcpp::sources::is_source::value
static const bool value
Definition: rx-sources.hpp:30