Searched refs:subjects (Results 1 – 25 of 61) 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
8 import io.reactivex.subjects.BehaviorSubject
8 import io.reactivex.subjects.*
15 namespace rxsub=rxcpp::subjects;
25 ${TEST_DIR}/subjects/subject.cpp
13 io.reactivex.subjects
7 namespace rxsub=rxcpp::subjects;
17 package com.android.textclassifier.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;
135 // new/delete oparators are subjects of cplusplus.NewDelete.173 // malloc()/free() are subjects of unix.Malloc and unix.MallocWithAnnotations
16 //----- malloc()/free() are subjects of unix.Malloc and unix.MallocWithAnnotations
45 learning about random subjects, you choose a random page number (see module
2027 my @subjects = ();2036 push(@subjects, $1) if ($line =~ m/$VCS_cmds{"subject_pattern"}/);2043 @{$ref}[1] eq $subjects[$i]) {2050 [ ($commits[$i], $subjects[$i]) ]);
42 learning about random subjects, you choose a random page number (see module