Searched refs:subject_type (Results 1 – 2 of 2) sorted by relevance
39 typedef rxu::decay_t<Subject> subject_type; typedef43 multicast_state(source_type o, subject_type sub) in multicast_state()49 subject_type subject_value;55 multicast(source_type o, subject_type sub) in multicast()
85 typedef rxsub::subject<marble_type> subject_type; typedef87 …typedef std::map<key_type, typename subject_type::subscriber_type, predicate_type> key_subscriber_…101 typedef typename traits_type::subject_type subject_type; typedef159 subject_type subject;162 group_by_observable(std::shared_ptr<group_by_state_type> st, subject_type s, key_type k) in group_by_observable()212 auto sub = subject_type(); in on_next()