Searched refs:subjects (Results 1 – 25 of 70) sorted by relevance
123
12 namespace subjects { namespace15 namespace rxsub=subjects;
79 mutable std::deque<rxcpp::subjects::subject<T>> subj;86 subj.push_back(rxcpp::subjects::subject<T>()); in window_observer()101 subj.push_back(rxcpp::subjects::subject<T>()); in on_next()
102 mutable rxcpp::subjects::subject<T> subj;150 state->subj = rxcpp::subjects::subject<T>(); in release_window()
104 mutable std::list<rxcpp::subjects::subject<T>> subj;142 … auto it = localState->subj.insert(localState->subj.end(), rxcpp::subjects::subject<T>()); in window_toggle_observer()
109 mutable std::deque<rxcpp::subjects::subject<T>> subj;158 localState->subj.push_back(rxcpp::subjects::subject<T>()); in window_with_time_observer()
104 ${RXCPP_DIR}/Rx/v2/src/rxcpp/rx-subjects.hpp129 ${RXCPP_DIR}/Rx/v2/src/rxcpp/subjects/rx-behavior.hpp130 ${RXCPP_DIR}/Rx/v2/src/rxcpp/subjects/rx-replaysubject.hpp131 ${RXCPP_DIR}/Rx/v2/src/rxcpp/subjects/rx-subject.hpp132 ${RXCPP_DIR}/Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp
15 namespace rxsub=rxcpp::subjects;
25 ${TEST_DIR}/subjects/subject.cpp
13 io.reactivex.subjects
7 namespace rxsub=rxcpp::subjects;
13 io.reactivex.rxjava3.subjects
12 namespace subjects { namespace
14 packages" or "resources" in any detail, as all of these subjects are
61 subjects::subject<Message> subject;
35 namespace rxsub=rxcpp::subjects;
16 //----- malloc()/free() are subjects of unix.Malloc and unix.MallocWithAnnotations
135 // new/delete oparators are subjects of cplusplus.NewDelete.173 // malloc()/free() are subjects of unix.Malloc and unix.MallocWithAnnotations
136 // new/delete oparators are subjects of cplusplus.NewDelete.174 // malloc()/free() are subjects of unix.Malloc and unix.MallocWithAnnotations
11 import io.reactivex.rxjava3.subjects.PublishSubject
112 repeated string subjects = 1; field
11 import io.reactivex.subjects.PublishSubject
45 learning about random subjects, you choose a random page number (see module
42 learning about random subjects, you choose a random page number (see module