| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscriber.hpp | 24 template<class T, class Observer = observer<T>>
27 static_assert(!is_subscriber<Observer>::value, "not allowed to nest subscribers");
28 static_assert(is_observer<Observer>::value, "subscriber must contain an observer<T, ...>");
29 typedef subscriber<T, Observer> this_type;
30 typedef rxu::decay_t<Observer> observer_type;
128 std::is_same<Observer, observer<T>>::value, void**>::type = nullptr) in subscriber() argument
223 template<class T, class Observer>
225 subscriber<T, Observer> o) in make_subscriber()
226 -> subscriber<T, Observer> { in make_subscriber()
227 return subscriber<T, Observer>(std::move(o)); in make_subscriber()
[all …]
|
| D | rx-observer.hpp | 359 template<class T, class Observer>
362 explicit specific_observer(Observer o) in specific_observer()
367 Observer destination;
405 template<class Observer>
406 static auto make_destination(Observer o) in make_destination()
408 return std::make_shared<detail::specific_observer<T, Observer>>(std::move(o)); in make_destination()
424 template<class Observer>
425 explicit observer(Observer o) in observer()
469 template<class T, class DefaultOnError = detail::OnErrorEmpty, class Observer>
470 auto make_observer(Observer ob) in make_observer()
[all …]
|
| /external/tensorflow/tensorflow/lite/tools/accuracy/ilsvrc/ |
| D | imagenet_model_evaluator.h | 77 class Observer {
79 Observer() = default;
80 Observer(const Observer&) = delete;
81 Observer& operator=(const Observer&) = delete;
83 Observer(const Observer&&) = delete;
84 Observer& operator=(const Observer&&) = delete;
96 virtual ~Observer() = default;
108 void AddObserver(Observer* observer) { observers_.push_back(observer); } in AddObserver()
119 std::vector<Observer*> observers_;
|
| /external/mockito/src/test/java/org/mockito/internal/util/reflection/ |
| D | ParameterizedConstructorInstantiatorTest.java | 22 import java.util.Observer;
71 Observer observer = mock(Observer.class); in should_instantiate_type_if_resolver_provide_matching_types()
84 Observer observer = mock(Observer.class); in should_fail_if_an_argument_instance_type_do_not_match_wanted_type()
110 Observer[] vararg = new Observer[] { }; in should_instantiate_type_with_vararg_constructor()
129 public OneConstructor(Observer observer) { } in OneConstructor()
133 … public ThrowingConstructor(Observer observer) throws IOException { throw new IOException(); } in ThrowingConstructor()
137 Observer observer;
140 public MultipleConstructor(Observer observer) { this(observer, null); } in MultipleConstructor()
141 public MultipleConstructor(Observer observer, Map map) { in MultipleConstructor()
149 VarargConstructor(String whatever, Observer... observers) { } in VarargConstructor()
|
| /external/setupdesign/main/src/com/google/android/setupdesign/items/ |
| D | AbstractItemHierarchy.java | 35 private final ArrayList<Observer> observers = new ArrayList<>();
59 public void registerObserver(Observer observer) { in registerObserver()
64 public void unregisterObserver(Observer observer) { in unregisterObserver()
70 for (Observer observer : observers) { in notifyChanged()
86 for (Observer observer : observers) { in notifyItemRangeChanged()
102 for (Observer observer : observers) { in notifyItemRangeInserted()
122 for (Observer observer : observers) { in notifyItemRangeMoved()
138 for (Observer observer : observers) { in notifyItemRangeRemoved()
|
| D | ItemHierarchy.java | 34 interface Observer { interface
63 void registerObserver(Observer observer); in registerObserver()
66 void unregisterObserver(Observer observer); in unregisterObserver()
|
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| D | bitrate.h | 30 class Observer;
31 Bitrate(Clock* clock, Observer* observer);
51 class Observer {
53 Observer() {} in Observer() function
54 virtual ~Observer() {} in ~Observer()
73 Observer* const observer_;
|
| /external/pdfium/core/fxcrt/ |
| D | shared_copy_on_write_unittest.cpp | 16 class Observer { class
34 Object(Observer* observer, const std::string& name) in Object()
45 Observer* observer_;
51 Observer observer; in TEST()
59 Observer observer; in TEST()
80 Observer observer; in TEST()
94 Observer observer; in TEST()
110 Observer observer; in TEST()
|
| /external/libchrome/mojo/core/ |
| D | mach_port_relay.h | 23 class MachPortRelay : public base::PortProvider::Observer {
25 class Observer {
70 void AddObserver(Observer* observer);
71 void RemoveObserver(Observer* observer);
82 std::set<Observer*> observers_;
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/pythagorian/ |
| D | main.cpp | 66 template<class Observer>
67 inline void on_next_return(const Observer&) { in on_next_return()
71 template<class Observer>
72 inline void on_error_return(const Observer&) { in on_error_return()
76 template<class Observer>
77 inline void on_completed_return(const Observer&) { in on_completed_return()
|
| /external/perfetto/src/traced/probes/ftrace/ |
| D | ftrace_controller.h | 55 class Observer {
57 virtual ~Observer();
62 static std::unique_ptr<FtraceController> Create(base::TaskRunner*, Observer*);
94 Observer*);
121 Observer* const observer_;
|
| /external/webrtc/webrtc/p2p/stunprober/ |
| D | stunprober.h | 64 class Observer {
66 virtual ~Observer() = default;
132 StunProber::Observer* observer);
135 bool Start(StunProber::Observer* observer);
154 class ObserverAdapter : public Observer {
242 Observer* observer_ = nullptr;
|
| /external/libchrome/mojo/public/cpp/system/ |
| D | file_data_pipe_producer.h | 37 class Observer {
39 virtual ~Observer() {} in ~Observer()
59 std::unique_ptr<Observer> observer);
106 std::unique_ptr<Observer> observer_;
|
| /external/libchrome/device/bluetooth/ |
| D | bluetooth_advertisement.h | 115 class Observer {
117 virtual ~Observer() {} in ~Observer()
125 void AddObserver(BluetoothAdvertisement::Observer* observer);
126 void RemoveObserver(BluetoothAdvertisement::Observer* observer);
146 base::ObserverList<BluetoothAdvertisement::Observer> observers_;
|
| /external/v8/src/interpreter/ |
| D | bytecode-register-allocator.h | 20 class Observer {
22 virtual ~Observer() {} in ~Observer()
95 void set_observer(Observer* observer) { observer_ = observer; } in set_observer()
103 Observer* observer_;
|
| /external/libchrome/base/metrics/ |
| D | field_trial.h | 406 class BASE_EXPORT Observer {
413 virtual ~Observer();
619 static bool AddObserver(Observer* observer);
622 static void RemoveObserver(Observer* observer);
633 static void SetSynchronousObserver(Observer* observer);
636 static void RemoveSynchronousObserver(Observer* observer);
778 scoped_refptr<ObserverListThreadSafe<Observer> > observer_list_;
781 Observer* synchronous_observer_ = nullptr;
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/tools/ |
| D | bwe_rtp_play.cc | 21 class Observer : public webrtc::RemoteBitrateObserver { class
23 explicit Observer(webrtc::Clock* clock) : clock_(clock) {} in Observer() function in Observer
34 virtual ~Observer() {} in ~Observer()
46 Observer observer(&clock); in main()
|
| /external/libchrome/base/task/sequence_manager/ |
| D | task_queue_selector.h | 57 class BASE_EXPORT Observer {
59 virtual ~Observer() = default;
67 void SetTaskQueueSelectorObserver(Observer* observer);
217 Observer* task_queue_selector_observer_; // Not owned.
|
| D | sequence_manager.h | 28 class Observer {
30 virtual ~Observer() = default;
62 virtual void SetObserver(Observer* observer) = 0;
|
| /external/libchrome/base/ |
| D | scoped_observer.h | 20 template <class Source, class Observer>
23 explicit ScopedObserver(Observer* observer) : observer_(observer) {} in ScopedObserver()
56 Observer* observer_;
|
| /external/libchrome/base/message_loop/ |
| D | incoming_task_queue.h | 31 class Observer {
33 virtual ~Observer() = default;
89 explicit IncomingTaskQueue(std::unique_ptr<Observer> task_queue_observer);
241 const std::unique_ptr<Observer> task_queue_observer_;
|
| /external/mockito/src/test/java/org/mockito/internal/util/collections/ |
| D | HashCodeAndEqualsSafeSetTest.java | 14 import java.util.Observer;
65 mock(Observer.class)); in can_add_a_collection()
78 mock(Observer.class)); in can_retain_a_collection()
93 mock(Observer.class)); in can_remove_a_collection()
108 mock(Observer.class)); in can_iterate()
|
| /external/mockito/src/test/java/org/mockito/internal/configuration/injection/ |
| D | ConstructorInjectionTest.java | 16 import java.util.Observer;
25 @Mock private Observer observer;
54 ArgConstructor(Observer observer) {} in ArgConstructor()
|
| /external/webrtc/talk/app/webrtc/java/src/org/webrtc/ |
| D | DataChannel.java | 79 public interface Observer { interface in DataChannel
103 public void registerObserver(Observer observer) { in registerObserver()
109 private native long registerObserverNative(Observer observer); in registerObserverNative()
|
| /external/clang/include/clang/Analysis/Analyses/ |
| D | LiveVariables.h | 53 class Observer {
56 virtual ~Observer() {} in ~Observer()
93 void runOnAllBlocks(Observer &obs);
|