| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-replay.hpp | 100 template<class Observable,
102 is_observable<Observable>>,
103 class SourceValue = rxu::value_type_t<Observable>,
105 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
108 static Result member(Observable&& o) { in member()
109 …return Result(Multicast(std::forward<Observable>(o), Subject(identity_current_thread(), composite_… in member()
112 template<class Observable,
114 is_observable<Observable>>,
115 class SourceValue = rxu::value_type_t<Observable>,
117 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
[all …]
|
| D | rx-publish.hpp | 94 template<class Observable,
96 is_observable<Observable>>,
97 class SourceValue = rxu::value_type_t<Observable>,
99 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
102 static Result member(Observable&& o) { in member()
103 return Result(Multicast(std::forward<Observable>(o), Subject(composite_subscription()))); in member()
106 template<class Observable,
108 is_observable<Observable>>,
109 class SourceValue = rxu::value_type_t<Observable>,
111 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
[all …]
|
| D | rx-repeat.hpp | 67 template <class T, class Observable, class Count>
69 <event_handlers, T, Observable, Count>;
72 template <class T, class Observable>
74 <event_handlers, T, Observable>;
91 template<class Observable,
92 class Enabled = rxu::enable_if_all_true_type_t<is_observable<Observable>>,
93 class SourceValue = rxu::value_type_t<Observable>,
94 class Repeat = rxo::detail::repeat::infinite<SourceValue, rxu::decay_t<Observable>>,
97 static Result member(Observable&& o) { in member()
98 return Result(Repeat(std::forward<Observable>(o))); in member()
[all …]
|
| D | rx-retry.hpp | 63 template <class T, class Observable, class Count>
65 <event_handlers, T, Observable, Count>;
68 template <class T, class Observable>
70 <event_handlers, T, Observable>;
88 template<class Observable,
89 class Enabled = rxu::enable_if_all_true_type_t<is_observable<Observable>>,
90 class SourceValue = rxu::value_type_t<Observable>,
91 class Retry = rxo::detail::retry::infinite<SourceValue, rxu::decay_t<Observable>>,
95 static Result member(Observable&& o) { in member()
96 return Result(Retry(std::forward<Observable>(o))); in member()
[all …]
|
| D | rx-zip.hpp | 49 template<class Observable>
52 using value_type = rxu::value_type_t<Observable>;
62 template<class Observable>
63 bool operator()(zip_source_state<Observable>& source) const { in operator ()()
69 template<class Observable>
70 bool operator()(zip_source_state<Observable>& source) const { in operator ()()
76 template<class Observable, class Value = rxu::value_type_t<Observable>>
77 Value operator()(zip_source_state<Observable>& source) const { in operator ()()
284 template<class Observable, class... ObservableN,
286 all_observables<Observable, ObservableN...>>,
[all …]
|
| D | rx-subscribe.hpp | 75 template<class Observable>
76 auto operator()(Observable&& source) in operator ()()
77 -> decltype(std::forward<Observable>(source).subscribe(std::move(scrbr))) { in operator ()()
78 return std::forward<Observable>(source).subscribe(std::move(scrbr)); in operator ()()
98 template<class Observable>
99 auto operator()(Observable&& source) in operator ()()
100 -> observable<rxu::value_type_t<rxu::decay_t<Observable>>> { in operator ()()
101 … return observable<rxu::value_type_t<rxu::decay_t<Observable>>>(std::forward<Observable>(source)); in operator ()()
127 template<class Observable>
128 auto operator()(Observable&& source) in operator ()()
[all …]
|
| D | rx-skip_until.hpp | 48 template<class T, class Observable, class TriggerObservable, class Coordination>
51 typedef rxu::decay_t<Observable> source_type;
211 template<class Observable, class TimePoint,
213 is_observable<Observable>,
215 class SourceValue = rxu::value_type_t<Observable>,
219 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
222 static Result member(Observable&& o, TimePoint&& when) { in member()
224 …return Result(SkipUntil(std::forward<Observable>(o), rxs::timer(std::forward<TimePoint>(when), cn)… in member()
227 template<class Observable, class TimePoint, class Coordination,
229 is_observable<Observable>,
[all …]
|
| D | rx-take_until.hpp | 58 template<class T, class Observable, class TriggerObservable, class Coordination>
61 typedef rxu::decay_t<Observable> source_type;
219 template<class Observable, class TimePoint,
221 is_observable<Observable>,
223 class SourceValue = rxu::value_type_t<Observable>,
227 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
230 static Result member(Observable&& o, TimePoint&& when) { in member()
232 …return Result(TakeUntil(std::forward<Observable>(o), rxs::timer(std::forward<TimePoint>(when), cn)… in member()
235 template<class Observable, class TimePoint, class Coordination,
237 is_observable<Observable>,
[all …]
|
| D | rx-reduce.hpp | 84 template<class T, class Observable, class Accumulator, class ResultSelector, class Seed>
87 typedef rxu::decay_t<Observable> source_type;
97 template<class T, class Observable, class Accumulator, class ResultSelector, class Seed>
98 struct reduce : public operator_base<rxu::value_type_t<reduce_traits<T, Observable, Accumulator, Re…
100 typedef reduce<T, Observable, Accumulator, ResultSelector, Seed> this_type;
101 typedef reduce_traits<T, Observable, Accumulator, ResultSelector, Seed> traits;
507 template<class Observable, class Seed, class Accumulator, class ResultSelector,
508 …class Reduce = rxo::detail::reduce<rxu::value_type_t<Observable>, rxu::decay_t<Observable>, rxu::d…
511 static Result member(Observable&& o, Seed&& s, Accumulator&& a, ResultSelector&& r) in member()
513 …return Result(Reduce(std::forward<Observable>(o), std::forward<Accumulator>(a), std::forward<Resul… in member()
[all …]
|
| D | rx-flat_map.hpp | 52 template<class Observable, class CollectionSelector, class ResultSelector, class Coordination>
54 typedef rxu::decay_t<Observable> source_type;
85 template<class Observable, class CollectionSelector, class ResultSelector, class Coordination>
87 …: public operator_base<rxu::value_type_t<flat_map_traits<Observable, CollectionSelector, ResultSel…
89 typedef flat_map<Observable, CollectionSelector, ResultSelector, Coordination> this_type;
90 typedef flat_map_traits<Observable, CollectionSelector, ResultSelector, Coordination> traits;
262 template<class Observable, class CollectionSelector,
264 class SourceValue = rxu::value_type_t<Observable>,
268 all_observables<Observable, CollectionType>>,
269 …class FlatMap = rxo::detail::flat_map<rxu::decay_t<Observable>, rxu::decay_t<CollectionSelector>, …
[all …]
|
| D | rx-sequence_equal.hpp | 45 template<class T, class Observable, class OtherObservable, class BinaryPredicate, class Coordinatio…
48 typedef rxu::decay_t<Observable> source_type;
220 template<class Observable, class OtherObservable,
222 is_observable<Observable>,
224 class SourceValue = rxu::value_type_t<Observable>,
225 …class SequenceEqual = rxo::detail::sequence_equal<SourceValue, rxu::decay_t<Observable>, rxu::deca…
228 static Result member(Observable&& o, OtherObservable&& t) { in member()
229 …return Result(SequenceEqual(std::forward<Observable>(o), std::forward<OtherObservable>(t), rxu::eq… in member()
232 template<class Observable, class OtherObservable, class BinaryPredicate,
235 is_observable<Observable>,
[all …]
|
| D | rx-merge.hpp | 64 template<class T, class Observable, class Coordination>
71 typedef merge<T, Observable, Coordination> this_type;
74 typedef rxu::decay_t<Observable> source_type;
226 template<class Observable,
228 is_observable<Observable>>,
229 class SourceValue = rxu::value_type_t<Observable>,
230 … class Merge = rxo::detail::merge<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
234 static Result member(Observable&& o) { in member()
235 return Result(Merge(std::forward<Observable>(o), identity_current_thread())); in member()
238 template<class Observable, class Coordination,
[all …]
|
| D | rx-merge_delay_error.hpp | 57 template<class T, class Observable, class Coordination>
64 typedef merge_delay_error<T, Observable, Coordination> this_type;
67 typedef rxu::decay_t<Observable> source_type;
240 template<class Observable,
242 is_observable<Observable>>,
243 class SourceValue = rxu::value_type_t<Observable>,
244 …class Merge = rxo::detail::merge_delay_error<SourceValue, rxu::decay_t<Observable>, identity_one_w…
248 static Result member(Observable&& o) { in member()
249 return Result(Merge(std::forward<Observable>(o), identity_current_thread())); in member()
252 template<class Observable, class Coordination,
[all …]
|
| D | rx-amb.hpp | 60 template<class T, class Observable, class Coordination>
67 typedef amb<T, Observable, Coordination> this_type;
70 typedef rxu::decay_t<Observable> source_type;
234 template<class Observable,
236 is_observable<Observable>>,
237 class SourceValue = rxu::value_type_t<Observable>,
238 class Amb = rxo::detail::amb<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
242 static Result member(Observable&& o) { in member()
243 return Result(Amb(std::forward<Observable>(o), identity_current_thread())); in member()
246 template<class Observable, class Coordination,
[all …]
|
| D | rx-concat.hpp | 62 template<class T, class Observable, class Coordination>
66 typedef concat<T, Observable, Coordination> this_type;
69 typedef rxu::decay_t<Observable> source_type;
245 template<class Observable,
247 is_observable<Observable>>,
248 class SourceValue = rxu::value_type_t<Observable>,
249 … class Concat = rxo::detail::concat<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
253 static Result member(Observable&& o) { in member()
254 return Result(Concat(std::forward<Observable>(o), identity_current_thread())); in member()
257 template<class Observable, class Coordination,
[all …]
|
| D | rx-concat_map.hpp | 52 template<class Observable, class CollectionSelector, class ResultSelector, class Coordination>
54 typedef rxu::decay_t<Observable> source_type;
87 template<class Observable, class CollectionSelector, class ResultSelector, class Coordination>
89 …: public operator_base<rxu::value_type_t<concat_traits<Observable, CollectionSelector, ResultSelec…
91 typedef concat_map<Observable, CollectionSelector, ResultSelector, Coordination> this_type;
92 typedef concat_traits<Observable, CollectionSelector, ResultSelector, Coordination> traits;
295 template<class Observable, class CollectionSelector,
297 class SourceValue = rxu::value_type_t<Observable>,
301 all_observables<Observable, CollectionType>>,
302 …class ConcatMap = rxo::detail::concat_map<rxu::decay_t<Observable>, rxu::decay_t<CollectionSelecto…
[all …]
|
| D | rx-group_by.hpp | 67 template<class T, class Observable, class KeySelector, class MarbleSelector, class BinaryPredicate,…
71 typedef rxu::decay_t<Observable> source_type;
92 template<class T, class Observable, class KeySelector, class MarbleSelector, class BinaryPredicate,…
95 …typedef group_by_traits<T, Observable, KeySelector, MarbleSelector, BinaryPredicate, DurationSelec…
298 template<class Observable>
301 typedef rxu::value_type_t<rxu::decay_t<Observable>> value_type;
302 …typedef detail::group_by_traits<value_type, Observable, KeySelector, MarbleSelector, BinaryPredica…
303 …typedef detail::group_by<value_type, Observable, KeySelector, MarbleSelector, BinaryPredicate, Dur…
305 template<class Observable>
306 auto operator()(Observable&& source) in operator ()()
[all …]
|
| D | rx-with_latest_from.hpp | 252 template<class Observable, class... ObservableN,
254 all_observables<Observable, ObservableN...>>,
255 …:with_latest_from<identity_one_worker, rxu::detail::pack, rxu::decay_t<Observable>, rxu::decay_t<O…
258 static Result member(Observable&& o, ObservableN&&... on) in member()
260 …m(identity_current_thread(), rxu::pack(), std::make_tuple(std::forward<Observable>(o), std::forwar… in member()
263 template<class Observable, class Selector, class... ObservableN,
265 operators::detail::is_with_latest_from_selector<Selector, Observable, ObservableN...>,
266 all_observables<Observable, ObservableN...>>,
268 …::with_latest_from<identity_one_worker, ResolvedSelector, rxu::decay_t<Observable>, rxu::decay_t<O…
271 static Result member(Observable&& o, Selector&& s, ObservableN&&... on) in member()
[all …]
|
| D | rx-combine_latest.hpp | 252 template<class Observable, class... ObservableN,
254 all_observables<Observable, ObservableN...>>,
255 …l::combine_latest<identity_one_worker, rxu::detail::pack, rxu::decay_t<Observable>, rxu::decay_t<O…
258 static Result member(Observable&& o, ObservableN&&... on) in member()
260 …t(identity_current_thread(), rxu::pack(), std::make_tuple(std::forward<Observable>(o), std::forwar… in member()
263 template<class Observable, class Selector, class... ObservableN,
265 operators::detail::is_combine_latest_selector<Selector, Observable, ObservableN...>,
266 all_observables<Observable, ObservableN...>>,
268 …il::combine_latest<identity_one_worker, ResolvedSelector, rxu::decay_t<Observable>, rxu::decay_t<O…
271 static Result member(Observable&& o, Selector&& s, ObservableN&&... on) in member()
[all …]
|
| D | rx-switch_on_next.hpp | 41 template<class T, class Observable, class Coordination>
48 typedef switch_on_next<T, Observable, Coordination> this_type;
51 typedef rxu::decay_t<Observable> source_type;
212 template<class Observable,
214 is_observable<Observable>>,
215 class SourceValue = rxu::value_type_t<Observable>,
216 …class SwitchOnNext = rxo::detail::switch_on_next<SourceValue, rxu::decay_t<Observable>, identity_o…
220 static Result member(Observable&& o) { in member()
221 return Result(SwitchOnNext(std::forward<Observable>(o), identity_current_thread())); in member()
224 template<class Observable, class Coordination,
[all …]
|
| D | rx-ref_count.hpp | 84 class Observable = void> // note: type order flipped versus the operator.
87 typedef rxu::decay_t<Observable> observable_type;
92 using has_observable_t = rxu::negation<std::is_same<void, Observable>>;
96 public ref_count_state_base<ConnectableObservable, Observable>
102 : ref_count_state_base<ConnectableObservable, Observable>(std::move(source)) in ref_count_state()
110 : ref_count_state_base<ConnectableObservable, Observable>(std::move(other), in ref_count_state()
194 template<class Observable,
197 is_observable<Observable>,
199 class SourceValue = rxu::value_type_t<Observable>,
202 rxu::decay_t<Observable>>,
[all …]
|
| D | rx-scan.hpp | 43 template<class T, class Observable, class Accumulator, class Seed>
46 typedef rxu::decay_t<Observable> source_type;
119 template<class Observable, class Seed, class Accumulator,
121 is_observable<Observable>,
122 …is_accumulate_function_for<rxu::value_type_t<Observable>, rxu::decay_t<Seed>, rxu::decay_t<Accumul…
123 class SourceValue = rxu::value_type_t<Observable>,
124 …class Scan = rxo::detail::scan<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Accumulator>, r…
127 static Result member(Observable&& o, Seed s, Accumulator&& a) { in member()
128 return Result(Scan(std::forward<Observable>(o), std::forward<Accumulator>(a), s)); in member()
|
| D | rx-multicast.hpp | 35 template<class T, class Observable, class Subject>
38 typedef rxu::decay_t<Observable> source_type;
102 template<class Observable, class Subject,
104 is_observable<Observable>>,
105 class SourceValue = rxu::value_type_t<Observable>,
106 …class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Subje…
109 static Result member(Observable&& o, Subject&& sub) { in member()
110 return Result(Multicast(std::forward<Observable>(o), std::forward<Subject>(sub))); in member()
|
| /external/syzkaller/vendor/golang.org/x/net/internal/timeseries/ |
| D | timeseries.go | 38 type Observable interface { interface
40 Add(other Observable) // Adds the data from a different observation to self argument
42 CopyFrom(other Observable) // Copies the contents of a given observation to self argument
49 func NewFloat() Observable {
62 func (f *Float) Add(other Observable) { argument
69 func (f *Float) CopyFrom(other Observable) { argument
93 buckets []Observable // collections of observations
94 provider func() Observable // used for creating new Observable
109 func (l *tsLevel) InitLevel(size time.Duration, numBuckets int, f func() Observable) {
112 l.buckets = make([]Observable, numBuckets)
[all …]
|
| /external/pdfium/core/fxcrt/ |
| D | observable.h | 16 class Observable {
58 Observable() = default;
59 Observable(const Observable& that) = delete;
60 ~Observable() { NotifyObservedPtrs(); } in ~Observable()
74 Observable& operator=(const Observable& that) = delete;
85 using fxcrt::Observable;
|