Home
last modified time | relevance | path

Searched defs:state_type (Results 1 – 22 of 22) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-retry-repeat-common.hpp18 …struct state_type : public std::enable_shared_from_this<state_type<Values, Subscriber, EventHandle… struct
21 typedef Subscriber output_type;
22 state_type(const Values& i, const output_type& oarg) in state_type() argument
28 void do_subscribe() { in do_subscribe()
55 composite_subscription source_lifetime;
56 output_type out;
57 composite_subscription::weak_subscription lifetime_token;
Drx-sequence_equal.hpp83 struct state_type in on_subscribe() struct
87 state_type(const values& vals, coordinator_type coor, const output_type& o) in on_subscribe() function
98 composite_subscription other_lifetime; in on_subscribe()
99 composite_subscription source_lifetime; in on_subscribe()
100 coordinator_type coordinator; in on_subscribe()
101 output_type out; in on_subscribe()
103 mutable std::list<source_value_type> source_values; in on_subscribe()
104 mutable std::list<other_source_value_type> other_values; in on_subscribe()
105 mutable bool source_completed; in on_subscribe()
106 mutable bool other_completed; in on_subscribe()
Drx-skip_until.hpp89 struct state_type in on_subscribe() struct
93 state_type(const values& i, coordinator_type coor, const output_type& oarg) in on_subscribe() argument
102 typename mode::type mode_value; in on_subscribe()
103 composite_subscription trigger_lifetime; in on_subscribe()
104 composite_subscription source_lifetime; in on_subscribe()
105 coordinator_type coordinator; in on_subscribe()
106 output_type out; in on_subscribe()
Drx-take_last.hpp71 struct state_type in on_subscribe() struct
75 state_type(const values& i, const output_type& oarg) in on_subscribe() argument
80 queue_type items; in on_subscribe()
81 output_type out; in on_subscribe()
Drx-skip_last.hpp71 struct state_type in on_subscribe() struct
75 state_type(const values& i, const output_type& oarg) in on_subscribe() function
80 queue_type items; in on_subscribe()
81 output_type out; in on_subscribe()
Drx-take.hpp77 struct state_type in on_subscribe() struct
81 state_type(const values& i, const output_type& oarg) in on_subscribe() argument
87 typename mode::type mode_value; in on_subscribe()
88 output_type out; in on_subscribe()
Drx-skip.hpp78 struct state_type in on_subscribe() struct
82 state_type(const values& i, const output_type& oarg) in on_subscribe() function
88 typename mode::type mode_value; in on_subscribe()
89 output_type out; in on_subscribe()
Drx-flat_map.hpp130 struct state_type in on_subscribe() struct
134 state_type(values i, coordinator_type coor, output_type oarg) in on_subscribe() argument
143 int pendingCompletions; in on_subscribe()
144 coordinator_type coordinator; in on_subscribe()
145 output_type out; in on_subscribe()
Drx-debounce.hpp96 typedef std::shared_ptr<debounce_subscriber_values> state_type; typedef
Drx-buffer_time_count.hpp102 typedef std::shared_ptr<buffer_with_time_or_count_subscriber_values> state_type; typedef
Drx-window_time_count.hpp104 typedef std::shared_ptr<window_with_time_or_count_subscriber_values> state_type; typedef
Drx-timeout.hpp103 typedef std::shared_ptr<timeout_subscriber_values> state_type; typedef
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/
Drx-scope.hpp75 struct state_type in on_subscribe() struct
79 state_type(values i, Subscriber o) in on_subscribe() argument
84 Subscriber out; in on_subscribe()
85 rxu::detail::maybe<resource_type> resource; in on_subscribe()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-subject.hpp33 struct state_type struct in rxcpp::subjects::detail::multicast_observer
36 explicit state_type(composite_subscription cs) in state_type() argument
41 std::mutex lock;
42 typename mode::type current;
43 rxu::error_ptr error;
44 composite_subscription lifetime;
/external/libcxx/src/
Dlocale.cpp1454 codecvt<char, char, mbstate_t>::do_out(state_type&, in do_out() argument
1464 codecvt<char, char, mbstate_t>::do_in(state_type&, in do_in() argument
1474 codecvt<char, char, mbstate_t>::do_unshift(state_type&, in do_unshift() argument
1494 codecvt<char, char, mbstate_t>::do_length(state_type&, in do_length() argument
3117 codecvt<char16_t, char, mbstate_t>::do_out(state_type&, in do_out() argument
3134 codecvt<char16_t, char, mbstate_t>::do_in(state_type&, in do_in() argument
3151 codecvt<char16_t, char, mbstate_t>::do_unshift(state_type&, in do_unshift() argument
3171 codecvt<char16_t, char, mbstate_t>::do_length(state_type&, in do_length() argument
3194 codecvt<char32_t, char, mbstate_t>::do_out(state_type&, in do_out() argument
3211 codecvt<char32_t, char, mbstate_t>::do_in(state_type&, in do_in() argument
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-connectable_observable.hpp33 struct state_type struct in rxcpp::dynamic_connectable_observable
36 typedef std::function<void(composite_subscription)> onconnect_type;
38 onconnect_type on_connect;
Drx-grouped_observable.hpp38 struct state_type struct in rxcpp::dynamic_grouped_observable
41 typedef std::function<key_type()> ongetkey_type;
43 ongetkey_type on_get_key;
Drx-observable.hpp39 struct state_type struct in rxcpp::dynamic_observable
42 typedef std::function<void(subscriber<T>)> onsubscribe_type;
44 onsubscribe_type on_subscribe;
/external/parameter-framework/asio-1.10.6/include/asio/detail/
Dsocket_ops.hpp56 typedef unsigned char state_type; typedef
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-test.hpp469 struct state_type in start() struct
472 typedef decltype(createSource()) source_type; in start()
474 std::unique_ptr<source_type> source; in start()
475 subscriber<T, rxt::testable_observer<T>> o; in start()
477 explicit state_type(subscriber<T, rxt::testable_observer<T>> o) in start() function
/external/libchrome/base/strings/
Dstring16.h81 typedef mbstate_t state_type; typedef
/external/libcxx/test/support/
Dconstexpr_char_traits.hpp26 typedef std::mbstate_t state_type; typedef