Home
last modified time | relevance | path

Searched refs:Subscribe (Results 1 - 25 of 166) sorted by relevance

1234567

/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/property/
H A Darray_property_event_handler.h36 bool Subscribe(const Property& property, T* instance, void (T::*callback)(const ArrayChange&)) in Subscribe() function in ArrayPropertyChangedEventHandler
39 return handler_.Subscribe( in Subscribe()
43 bool Subscribe(const Property& property, void (*callback)(const ArrayChange&)) in Subscribe() function
46 return handler_.Subscribe(property, [=]() { callback(changesRecognizer_.OnArrayPropertyChanged(property)); }); in Subscribe()
50 bool Subscribe(const Property& property, Func func, const ITaskQueue::Ptr& queue = nullptr)
53 return handler_.Subscribe(
60 bool Subscribe(const Property& property, Func func, const BASE_NS::Uid& queueId)
63 return handler_.Subscribe(
H A Dproperty_event_handler.h38 bool Subscribe(const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked) in Subscribe() function in PropertyEventHandler
44 bool Subscribe(const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked, const ITaskQueue::Ptr& queue) in Subscribe() function in PropertyEventHandler
46 return handler_.Subscribe<EventType>((property.get()->*EventFunc)(), onInvoked, queue); in Subscribe()
49 bool Subscribe(const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked, const BASE_NS::Uid& queueId) in Subscribe() function in PropertyEventHandler
51 return handler_.Subscribe<EventType>((property.get()->*EventFunc)(), onInvoked, queueId); in Subscribe()
55 bool Subscribe(const IProperty::ConstPtr& property, Func func, const ITaskQueue::Ptr& queue = nullptr) in Subscribe() function in PropertyEventHandler
57 return handler_.Subscribe<EventType>((property.get()->*EventFunc)(), BASE_NS::move(func), queue); in Subscribe()
61 bool Subscribe(const IProperty::ConstPtr& property, Func func, const BASE_NS::Uid& queueId) in Subscribe() function in PropertyEventHandler
63 return handler_.Subscribe<EventType>((property.get()->*EventFunc)(), BASE_NS::move(func), queueId); in Subscribe()
83 Subscribe(propert in PropertyChangedEventHandler()
[all...]
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/
H A Devent_handler.h33 * Calling Subscribe when already subscribed will remove the old subscription.
60 Subscribe(event, func, queue); in EventHandler()
67 Subscribe(event, func, queueId); in EventHandler()
79 Subscribe(event, BASE_NS::move(func), queue); in EventHandler()
87 Subscribe(event, BASE_NS::move(func), queueId); in EventHandler()
99 * @brief Subscribe to an event.
119 * @brief Subscribe to an event.
126 bool Subscribe(const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, in Subscribe() function in EventHandler
137 * @brief Subscribe to an event.
144 bool Subscribe( in Subscribe() function
160 bool Subscribe(const Event<EventType>& event, Func func, const ITaskQueue::Ptr& queue = nullptr) Subscribe() function
170 bool Subscribe(const Event<EventType>& event, Func func, const BASE_NS::Uid& queueId) Subscribe() function
180 bool Subscribe(const BASE_NS::shared_ptr<IEvent>& event, Func func, const ITaskQueue::Ptr& queue = nullptr) Subscribe() function
191 bool Subscribe(const BASE_NS::shared_ptr<IEvent>& event, Func func, const BASE_NS::Uid& queueId) Subscribe() function
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/test/
H A Daccount_delegate_test.cpp82 auto status = account->Subscribe(nullptr); in HWTEST_F()
86 status = account->Subscribe(observer); in HWTEST_F()
102 auto status = account->Subscribe(observer); in HWTEST_F()
105 status = account->Subscribe(observer); in HWTEST_F()
120 auto status = account->Subscribe(observer); in HWTEST_F()
123 status = account->Subscribe(observer); in HWTEST_F()
126 status = account->Subscribe(observer); in HWTEST_F()
164 account->Subscribe(observer); in HWTEST_F()
168 status = account->Subscribe(observer); in HWTEST_F()
171 status = account->Subscribe(observe in HWTEST_F()
[all...]
/foundation/graphic/graphic_3d/lume/metaobject/src/
H A Dcontainer_observer.cpp60 bool ContainerChangeListener::Subscribe(const IOnChildChanged::InterfaceTypePtr& onAdded, in Subscribe() function in ContainerChangeListener
108 Subscribe(container_); in SetContainer()
114 Subscribe(interface_pointer_cast<IContainer>(info.object)); in InvokeAdded()
128 void ContainerObserver::Subscribe(const IContainer::Ptr& base) in Subscribe() function in ContainerObserver
134 listener.Subscribe(addedCallable_, removedCallable_, movedCallable_); in Subscribe()
139 Subscribe(child); in Subscribe()
H A Dobject_hierarchy_observer.cpp37 Subscribe(mode); in ObjectChangeListener()
96 bool ObjectChangeListener::Subscribe(HierarchyChangeModeValue mode) in Subscribe() function in ObjectChangeListener
234 Subscribe(root, HierarchyChangeObjectType::ROOT); in SetTarget()
299 Subscribe(info.object, info.objectType, info.parent); in HierarchyChanged()
313 void ObjectHierarchyObserver::Subscribe( in Subscribe() function in ObjectHierarchyObserver
328 Subscribe(child, HierarchyChangeObjectType::CHILD, root); in Subscribe()
337 Subscribe(object, HierarchyChangeObjectType::CONTENT, root); in Subscribe()
H A Dcontainer_observer.h39 bool Subscribe(const IOnChildChanged::InterfaceTypePtr& onAdded, const IOnChildChanged::InterfaceTypePtr& onRemoved,
66 void Subscribe(const IContainer::Ptr& base);
H A Dproxy_object.cpp63 metaAdded_.Subscribe<IOnChildChanged>( in Build()
65 metaRemoved_.Subscribe<IOnChildChanged>( in Build()
128 targetAddedListener_.Subscribe<IOnChildChanged>( in ListenTargetChanges()
130 targetRemovedListener_.Subscribe<IOnChildChanged>( in ListenTargetChanges()
/foundation/communication/dsoftbus/core/discovery/ble/share_ble/src/
H A Ddisc_share_ble_virtual.c46 static int32_t Subscribe(const SubscribeOption *option) in Subscribe() function
82 .Subscribe = Subscribe,
/foundation/graphic/graphic_3d/lume/scenewidgetplugin/plugin/src/
H A Dtextureinfo_impl.cpp90 handler_.Subscribe(array_, MakeCallback<IOnChanged>(this, &TextureInfoImpl::ArrayChanged));
92 handlers_[0].Subscribe(Image(), MakeCallback<IOnChanged>(this, &TextureInfoImpl::ImageChanged));
93 handlers_[1].Subscribe(Sampler(), MakeCallback<IOnChanged>(this, &TextureInfoImpl::SamplerChanged));
94 handlers_[2].Subscribe(Factor(), MakeCallback<IOnChanged>(this, &TextureInfoImpl::FactorChanged)); // 2 index
96 handlers_[3].Subscribe(Translation(), MakeCallback<IOnChanged>(this, &TextureInfoImpl::TranslationChanged));
97 handlers_[4].Subscribe(Rotation(), MakeCallback<IOnChanged>(this, &TextureInfoImpl::RotationChanged)); // 4 index
98 handlers_[5].Subscribe(Scale(), MakeCallback<IOnChanged>(this, &TextureInfoImpl::ScaleChanged)); // 5 index
H A Danim_impl.cpp295 propHandler_.NewHandler(nullptr, nullptr).Subscribe(animationSpeed_, [this]() { UpdateTotalDuration(); });
298 propHandler_.NewHandler(nullptr, nullptr).Subscribe(animationRepeatCount_, [this]() {
303 propHandler_.NewHandler(nullptr, nullptr).Subscribe(animationOrigDuration_, [this]() {
308 propHandler_.NewHandler(nullptr, nullptr).Subscribe(animationStateTime_, [this]() { UpdateProgress(); });
310 propHandler_.NewHandler(nullptr, nullptr).Subscribe(Enabled(), [this] {
334 .Subscribe(META_ACCESS_PROPERTY(ConnectionStatus), META_NS::MakeCallback<META_NS::IOnChanged>([this]() {
339 .Subscribe(META_ACCESS_PROPERTY(Progress), META_NS::MakeCallback<META_NS::IOnChanged>([this]() {
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_store_subscribe_test.cpp228 auto status = store->Subscribe({ SubscribeMode::REMOTE, "observer" }, observer_.get()); in HWTEST_F()
245 auto status = store->Subscribe({ SubscribeMode::CLOUD, "observer" }, observer_.get()); in HWTEST_F()
262 auto status = store->Subscribe({ SubscribeMode::CLOUD_DETAIL, "observer" }, observer_.get()); in HWTEST_F()
279 auto status = store->Subscribe({ SubscribeMode::LOCAL, "observer1" }, observer_.get()); in HWTEST_F()
280 store->Subscribe({ SubscribeMode::LOCAL, "observer1" }, observer_.get()); in HWTEST_F()
282 store->Subscribe({ SubscribeMode::LOCAL, "observer2" }, observer_.get()); in HWTEST_F()
318 auto status = store->Subscribe({ SubscribeMode::LOCAL_SHARED, "observer1" }, observer_.get()); in HWTEST_F()
319 store->Subscribe({ SubscribeMode::LOCAL_SHARED, "observer1" }, observer_.get()); in HWTEST_F()
321 store->Subscribe({ SubscribeMode::LOCAL_SHARED, "observer2" }, observer_.get()); in HWTEST_F()
602 auto status = SqlStatistic::Subscribe(sqlObserver in HWTEST_F()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/
H A Devent_center_test.cpp47 EventCenter::GetInstance().Subscribe(TEST_EVT_BEGIN, [this](const Event &evt) { in SetUp()
54 EventCenter::GetInstance().Subscribe(TEST_EVT_MIDDLE, [this](const Event &evt) { in SetUp()
61 EventCenter::GetInstance().Subscribe(TEST_EVT_END, [this](const Event &evt) { in SetUp()
/foundation/distributeddatamgr/pasteboard/framework/test/src/
H A Devent_center_test.cpp50 EventCenter::GetInstance().Subscribe(TEST_EVT_BEGIN, [this](const Event &evt) { in SetUp()
57 EventCenter::GetInstance().Subscribe(TEST_EVT_MIDDLE, [this](const Event &evt) { in SetUp()
64 EventCenter::GetInstance().Subscribe(TEST_EVT_END, [this](const Event &evt) { in SetUp()
/foundation/communication/netmanager_base/frameworks/js/napi/network/network_module/src/
H A Dnetwork_module.cpp31 DECLARE_NAPI_FUNCTION(FUNCTION_SUBSCRIBE, Subscribe), in InitNetworkModule()
57 napi_value NetworkModule::Subscribe(napi_env env, napi_callback_info info) in Subscribe() function in OHOS::NetManagerStandard::NetworkModule
59 NETMANAGER_BASE_LOGI("Subscribe is called"); in Subscribe()
/foundation/communication/netmanager_base/frameworks/js/napi/network/network_module/include/
H A Dnetwork_module.h36 static napi_value Subscribe(napi_env env, napi_callback_info info);
/foundation/communication/dsoftbus/tests/core/discovery/coap/unittest/
H A Ddisc_coap_test.cpp411 int32_t ret = g_discCoapFuncInterface->Subscribe(nullptr); in HWTEST_F()
416 ret = g_discCoapFuncInterface->Subscribe(&g_testSubOption); in HWTEST_F()
438 int32_t ret = g_discCoapFuncInterface->Subscribe(&g_testSubOption); in HWTEST_F()
462 ret = g_discCoapFuncInterface->Subscribe(&g_testSubOption); in HWTEST_F()
468 ret = g_discCoapFuncInterface->Subscribe(&g_testSubOption); in HWTEST_F()
474 ret = g_discCoapFuncInterface->Subscribe(&g_testSubOption); in HWTEST_F()
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/container/
H A Dfind_cache.h47 addedHandler_.Subscribe(container->OnAdded(), cb); in SetTarget()
48 removedHandler_.Subscribe(container->OnRemoved(), cb); in SetTarget()
/foundation/communication/dsoftbus/tests/core/discovery/manager/unittest/
H A Dble_mock.cpp60 return Get()->Subscribe(option); in BleSubscribe()
117 EXPECT_CALL(*this, Subscribe(NotNull())).WillRepeatedly(Return(SOFTBUS_OK)); in SetupStub()
H A Dcoap_mock.cpp60 return Get()->Subscribe(option); in CoapSubscribe()
109 EXPECT_CALL(*this, Subscribe(NotNull())).WillRepeatedly(Return(SOFTBUS_OK)); in SetupStub()
H A Dble_mock.h30 virtual int32_t Subscribe(const SubscribeOption *option) = 0;
52 MOCK_METHOD(int32_t, Subscribe, (const SubscribeOption* option), (override));
H A Dcoap_mock.h30 virtual int32_t Subscribe(const SubscribeOption *option) = 0;
51 MOCK_METHOD(int32_t, Subscribe, (const SubscribeOption* option), (override));
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/
H A Dmeta_data_manager.h78 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/multimodalinput/input/intention/stationary/server/src/
H A Dstationary_server.cpp77 Subscribe(context, param.type_, param.event_, param.latency_, param.callback_); in AddWatch()
129 void StationaryServer::Subscribe(CallingContext &context, Type type, ActivityEvent event, in Subscribe() function in OHOS::Msdp::DeviceStatus::StationaryServer
144 manager_.Subscribe(type, event, latency, callback); in Subscribe()
182 std::string(enable ? "Subscribe" : "Unsubscribe"), in ReportSensorSysEvent()
/foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/
H A Dpub_sub_implement.c23 static int Subscribe(IUnknown *iUnknown, const Topic *topic, Consumer *consumer);
33 .subscriber.Subscribe = Subscribe,
77 static int Subscribe(IUnknown *iUnknown, const Topic *topic, Consumer *consumer) in Subscribe() function

Completed in 14 milliseconds

1234567