/foundation/distributeddatamgr/data_share/frameworks/js/napi/common/include/ |
H A D | napi_callbacks_manager.h | 26 template<class Key, class Observer> 29 std::vector<OperationResult> AddObservers(const std::vector<Key> &keys, const std::shared_ptr<Observer> observer, 30 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer)>, 31 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, 35 const std::shared_ptr<Observer> observer = nullptr, 36 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, 39 std::vector<std::shared_ptr<Observer>> GetEnabledObservers(const Key &); 44 static void DefaultProcess(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, in DefaultProcess() 47 std::shared_ptr<Observer> observer_; 49 ObserverNode(const std::shared_ptr<Observer> [all...] |
/foundation/distributeddatamgr/data_share/frameworks/native/common/include/ |
H A D | callbacks_manager.h | 27 template<class Key, class Observer> 31 ObserverNodeOnEnabled(const std::shared_ptr<Observer> &observer, bool isNotifyOnEnabled = false) in ObserverNodeOnEnabled() 33 std::shared_ptr<Observer> observer_; 38 const std::shared_ptr<Observer> observer, 39 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer)>, 40 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, 59 std::vector<std::shared_ptr<Observer>> GetEnabledObservers(const Key &); 69 std::shared_ptr<Observer> observer_; 73 ObserverNode(const std::shared_ptr<Observer> &observer, void *subscriber) in ObserverNode() 87 template<class Key, class Observer> [all...] |
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/container/ |
H A D | object_hierarchy_observer.h | 32 META_API_CACHE_INTERFACE(META_NS::IObjectHierarchyObserver, Observer) 39 META_API_CACHED_INTERFACE(Observer)->SetTarget(root); in Target() 44 META_API_CACHED_INTERFACE(Observer)->SetTarget(root, mode); in Target() 52 return META_API_CACHED_INTERFACE(Observer)->GetTarget(); in GetTarget() 59 return META_API_CACHED_INTERFACE(Observer)->GetAllObserved(); in GetAllObserved() 73 META_API_CACHED_INTERFACE(Observer)->OnHierarchyChanged()->AddHandler( in OnHierarchyChanged()
|
H A D | container_observer.h | 32 META_API_CACHE_INTERFACE(META_NS::IContainerObserver, Observer) 39 META_API_CACHED_INTERFACE(Observer)->SetContainer(container); in Container() 48 META_API_CACHED_INTERFACE(Observer)->OnDescendantAdded()->AddHandler( in OnDescendantAdded() 58 META_API_CACHED_INTERFACE(Observer)->OnDescendantRemoved()->AddHandler( in OnDescendantRemoved() 68 META_API_CACHED_INTERFACE(Observer)->OnDescendantMoved()->AddHandler( in OnDescendantMoved()
|
/foundation/arkui/ace_engine_lite/frameworks/packages/runtime-core/src/observer/ |
H A D | observer.js | 18 * Observer constructor 22 * @param {Object} meta meta data that Observer object don't care about 24 export function Observer(context, getter, callback, meta) { 32 Observer.prototype._get = function() { 41 Observer.prototype.update = function() { 53 Observer.prototype.subscribe = function(subject, key) { 65 Observer.prototype.unsubscribe = function() { 30 Observer.prototype._get = function() { global() class
|
/foundation/communication/dsoftbus/sdk/frame/common/src/ |
H A D | softbus_client_event_manager.c | 32 } Observer; typedef 101 Observer *observer = (Observer *)SoftBusCalloc(sizeof(Observer)); in RegisterEventCallback() 131 Observer *observer = NULL; in CLIENT_NotifyObserver() 137 LIST_FOR_EACH_ENTRY(observer, &g_observerList->list, Observer, node) { in CLIENT_NotifyObserver()
|
/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/include/ |
H A D | dsoftbus_adapter_impl.h | 33 class Observer final { 35 explicit Observer(std::shared_ptr<IDSoftbusObserver> observer) in Observer() function in OHOS::Msdp::DeviceStatus::final::final 38 Observer() = default; 39 ~Observer() = default; 40 DISALLOW_COPY_AND_MOVE(Observer); 47 bool operator<(const Observer &other) const noexcept 110 std::set<Observer> observers_;
|
/foundation/multimodalinput/input/intention/adapters/ddm_adapter/include/ |
H A D | ddm_adapter_impl.h | 47 class Observer final { 49 explicit Observer(std::shared_ptr<IBoardObserver> observer) in Observer() function in OHOS::Msdp::DeviceStatus::final::final 52 Observer() = default; 53 ~Observer() = default; 54 DISALLOW_COPY_AND_MOVE(Observer); 61 bool operator<(const Observer &other) const noexcept 114 std::set<Observer> observers_;
|
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/ |
H A D | napi_subscriber_manager.cpp | 36 keys, std::make_shared<Observer>(env, callback), in AddObservers() 37 [this](const std::vector<Key> &localRegisterKeys, const std::shared_ptr<Observer> observer) { in AddObservers() 41 const std::shared_ptr<Observer> observer, std::vector<OperationResult> &opResult) { in AddObservers() 79 return BaseCallbacks::DelObservers(keys, callback == nullptr ? nullptr : std::make_shared<Observer>(env, callback), in DelObservers() 81 const std::shared_ptr<Observer> &observer, std::vector<OperationResult> &opResult) { in DelObservers() 107 void NapiRdbSubscriberManager::Emit(const std::vector<Key> &keys, const std::shared_ptr<Observer> &observer) in Emit() 131 keys, std::make_shared<Observer>(env, callback), in AddObservers() 132 [this](const std::vector<Key> &localRegisterKeys, const std::shared_ptr<Observer> observer) { in AddObservers() 136 const std::shared_ptr<Observer> observer, std::vector<OperationResult> &opResult) { in AddObservers() 174 return BaseCallbacks::DelObservers(keys, callback == nullptr ? nullptr : std::make_shared<Observer>(en [all...] |
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/ohos/ |
H A D | rs_accessibility.cpp | 31 class Observer : public AccessibilityConfigObserver { class in OHOS::Rosen::RSAccessibilityOHOS 38 std::shared_ptr<Observer> observer_ = std::make_shared<Observer>(); 70 void RSAccessibilityOHOS::Observer::OnConfigChanged(const CONFIG_ID id, const ConfigValue &value) in OnConfigChanged()
|
/foundation/distributeddatamgr/pasteboard/framework/framework/include/device/ |
H A D | distributed_module_config.h | 29 using Observer = std::function<void(bool isOn)>; 31 void Watch(Observer observer); 45 Observer observer_ = nullptr;
|
H A D | dev_profile.h | 31 using Observer = std::function<void(bool isEnable)>; 40 void Watch(Observer observer); 72 Observer observer_ = nullptr;
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/account/ |
H A D | account_delegate.h | 45 class Observer { class in OHOS::DistributedKv::AccountDelegate 51 API_EXPORT virtual ~Observer() = default; 60 API_EXPORT virtual Status Subscribe(std::shared_ptr<Observer> observer) = 0; 61 API_EXPORT virtual Status Unsubscribe(std::shared_ptr<Observer> observer) = 0;
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
H A D | account_delegate_impl.h | 46 Status Subscribe(std::shared_ptr<Observer> observer) override __attribute__((no_sanitize("cfi"))); 47 Status Unsubscribe(std::shared_ptr<Observer> observer) override __attribute__((no_sanitize("cfi"))); 54 ConcurrentMap<std::string, std::shared_ptr<Observer>> observerMap_ {};
|
H A D | account_delegate_impl.cpp | 65 if (val->GetLevel() == AccountDelegate::Observer::LevelType::HIGH) { in NotifyAccountChanged() 71 if (val->GetLevel() == AccountDelegate::Observer::LevelType::LOW) { in NotifyAccountChanged() 78 Status AccountDelegateImpl::Subscribe(std::shared_ptr<Observer> observer) in Subscribe() 97 Status AccountDelegateImpl::Unsubscribe(std::shared_ptr<Observer> observer) in Unsubscribe()
|
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
H A D | observer_bridge.h | 26 using Observer = DistributedKv::KvStoreObserver; 31 ObserverBridge(AppId appId, StoreId storeId, std::shared_ptr<Observer> observer, const Convertor &cvt); 41 ObserverClient(std::shared_ptr<Observer> observer, const Convertor &cvt);
|
H A D | single_store_impl.h | 37 using Observer = KvStoreObserver; 59 Status SubscribeKvStore(SubscribeType type, std::shared_ptr<Observer> observer) override; 60 Status UnSubscribeKvStore(SubscribeType type, std::shared_ptr<Observer> observer) override; 102 std::shared_ptr<ObserverBridge> PutIn(uint32_t &realType, std::shared_ptr<Observer> observer); 103 std::shared_ptr<ObserverBridge> TakeOut(uint32_t &realType, std::shared_ptr<Observer> observer);
|
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/include/ |
H A D | napi_subscriber_manager.h | 59 using Observer = NapiRdbObserver; 70 void Emit(const std::vector<Key> &keys, const std::shared_ptr<Observer> &observer); 104 using Observer = NapiPublishedObserver; 115 void Emit(const std::vector<Key> &keys, const std::shared_ptr<Observer> &observer);
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/ |
H A D | meta_data_manager.h | 48 using Observer = std::function<bool(const std::string &, const std::string &, int32_t)>; 78 API_EXPORT bool Subscribe(std::shared_ptr<Filter> filter, Observer observer); 79 API_EXPORT bool Subscribe(std::string prefix, Observer observer, bool isLocal = false);
|
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
H A D | rdb_types_util.cpp | 163 return Marshal(data, input[Observer::CHG_TYPE_INSERT], input[Observer::CHG_TYPE_UPDATE], in Marshalling() 164 input[Observer::CHG_TYPE_DELETE]); in Marshalling() 169 return Unmarshal(data, output[Observer::CHG_TYPE_INSERT], output[Observer::CHG_TYPE_UPDATE], in Unmarshalling() 170 output[Observer::CHG_TYPE_DELETE]); in Unmarshalling()
|
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
H A D | rdb_types_util.h | 39 using Observer = DistributedRdb::RdbStoreObserver; 41 using ChangeInfo = Observer::ChangeInfo; 42 using PrimaryKey = Observer::PrimaryKey; 43 using PrimaryKeys = std::vector<PrimaryKey>[Observer::CHG_TYPE_BUTT];
|
/foundation/arkui/ace_engine_lite/frameworks/packages/runtime-core/src/core/ |
H A D | index.js | 15 import { Observer, Subject } from '../observer'; 63 return new Observer(this, getter, callback, meta);
|
/foundation/multimodalinput/input/intention/adapters/ddm_adapter/src/ |
H A D | ddm_adapter_impl.cpp | 99 observers_.erase(Observer()); in AddBoardObserver() 108 observers_.erase(Observer()); in RemoveBoardObserver() 109 if (auto iter = observers_.find(Observer(observer)); iter != observers_.end()) { in RemoveBoardObserver()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
H A D | meta_data_manager.cpp | 29 using Observer = MetaDataManager::Observer; 33 MetaObserver(std::shared_ptr<MetaStore> metaStore, std::shared_ptr<Filter> filter, Observer observer, 46 Observer observer_; 50 std::shared_ptr<MetaStore> metaStore, std::shared_ptr<Filter> filter, Observer observer, bool isLocal) in MetaObserver() 309 bool MetaDataManager::Subscribe(std::shared_ptr<Filter> filter, Observer observer) in Subscribe() 320 bool MetaDataManager::Subscribe(std::string prefix, Observer observer, bool isLocal) in Subscribe()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
H A D | store_account_observer.h | 21 class RuntimeStoreAccountObserver : public DistributedKv::AccountDelegate::Observer {
|