Searched refs:operator_base (Results 1 – 25 of 61) sorted by relevance
123
28 struct connect_forever_invalid : public rxo::operator_base<connect_forever_invalid_arguments<AN...>…35 struct connect_forever : public operator_base<T>
29 struct multicast_invalid : public rxo::operator_base<multicast_invalid_arguments<AN...>> {36 struct multicast : public operator_base<T>
62 struct finite : public operator_base<T> {113 struct infinite : public operator_base<T> {
37 struct scan_invalid : public rxo::operator_base<scan_invalid_arguments<AN...>> {44 struct scan : public operator_base<rxu::decay_t<Seed>>
35 struct take_invalid : public rxo::operator_base<take_invalid_arguments<AN...>> {42 struct take : public operator_base<T>
35 struct skip_invalid : public rxo::operator_base<skip_invalid_arguments<AN...>> {43 struct skip : public operator_base<T>
35 struct take_last_invalid : public rxo::operator_base<take_last_invalid_arguments<AN...>> {42 struct take_last : public operator_base<T>
35 struct skip_last_invalid : public rxo::operator_base<skip_last_invalid_arguments<AN...>> {42 struct skip_last : public operator_base<T>
38 struct subscribe_on_invalid : public rxo::operator_base<subscribe_on_invalid_arguments<AN...>> {45 struct subscribe_on : public operator_base<T>
44 struct ref_count_invalid : public rxo::operator_base<ref_count_invalid_arguments<AN...>> {85 struct ref_count : public operator_base<T>
35 struct switch_on_next_invalid : public rxo::operator_base<switch_on_next_invalid_arguments<AN...>> {43 : public operator_base<rxu::value_type_t<rxu::decay_t<T>>>
58 struct merge_invalid : public rxo::operator_base<merge_invalid_arguments<AN...>> {66 : public operator_base<rxu::value_type_t<rxu::decay_t<T>>>
42 struct start_with_invalid : public rxo::operator_base<start_with_invalid_arguments<AN...>> {
54 struct amb_invalid : public rxo::operator_base<amb_invalid_arguments<AN...>> {62 : public operator_base<rxu::value_type_t<T>>
42 struct skip_until_invalid : public rxo::operator_base<skip_until_invalid_arguments<AN...>> {49 struct skip_until : public operator_base<T>
56 struct concat_invalid : public rxo::operator_base<concat_invalid_arguments<AN...>> {64 : public operator_base<rxu::value_type_t<rxu::decay_t<T>>>
52 struct take_until_invalid : public rxo::operator_base<take_until_invalid_arguments<AN...>> {59 struct take_until : public operator_base<T>
31 struct ignore_elements_invalid : public rxo::operator_base<ignore_elements_invalid_arguments<AN...>…
39 struct sequence_equal_invalid : public rxo::operator_base<sequence_equal_invalid_arguments<AN...>> {46 struct sequence_equal : public operator_base<bool>
53 struct with_latest_from_invalid : public rxo::operator_base<with_latest_from_invalid_arguments<AN..…102 struct with_latest_from : public operator_base<rxu::value_type_t<with_latest_from_traits<Coordinati…
53 struct combine_latest_invalid : public rxo::operator_base<combine_latest_invalid_arguments<AN...>> {102 struct combine_latest : public operator_base<rxu::value_type_t<combine_latest_traits<Coordination, …
33 struct distinct_invalid : public rxo::operator_base<distinct_invalid_arguments<AN...>> {
35 struct skip_while_invalid : public rxo::operator_base<skip_while_invalid_arguments<AN...>> {
39 struct finally_invalid : public rxo::operator_base<finally_invalid_arguments<AN...>> {
40 struct repeat_invalid : public rxo::operator_base<repeat_invalid_arguments<AN...>> {