Home
last modified time | relevance | path

Searched refs:firstAddUris (Results 1 - 3 of 3) sorted by relevance

/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/
H A Dnapi_subscriber_manager.cpp42 std::vector<std::string> firstAddUris; in AddObservers() variable
43 std::for_each(firstAddKeys.begin(), firstAddKeys.end(), [&firstAddUris](auto &result) { in AddObservers()
44 firstAddUris.emplace_back(result); in AddObservers()
46 if (firstAddUris.empty()) { in AddObservers()
50 datashareHelper->SubscribeRdbData(firstAddUris, templateId, [this](const RdbChangeNode &changeNode) { in AddObservers()
137 std::vector<std::string> firstAddUris; in AddObservers() variable
138 std::for_each(firstAddKeys.begin(), firstAddKeys.end(), [&firstAddUris](auto &result) { in AddObservers()
139 firstAddUris.emplace_back(result); in AddObservers()
141 if (firstAddUris.empty()) { in AddObservers()
144 auto subResults = dataShareHelper->SubscribePublishedData(firstAddUris, subscriberI in AddObservers()
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Dpublished_data_subscriber_manager.cpp45 std::vector<std::string> firstAddUris; in AddObservers() variable
46 std::for_each(firstAddKeys.begin(), firstAddKeys.end(), [&firstAddUris](auto &result) { in AddObservers()
47 firstAddUris.emplace_back(result); in AddObservers()
49 if (firstAddUris.empty()) { in AddObservers()
54 auto subResults = proxy->SubscribePublishedData(firstAddUris, subscriberId, serviceCallback_); in AddObservers()
141 std::vector<std::string> firstAddUris;
142 std::for_each(firstAddKeys.begin(), firstAddKeys.end(), [&firstAddUris](auto &result) {
143 firstAddUris.emplace_back(result);
145 if (firstAddUris.empty()) {
148 auto subResults = proxy->EnableSubscribePublishedData(firstAddUris, subscriberI
[all...]
H A Drdb_subscriber_manager.cpp56 std::vector<std::string> firstAddUris; in AddObservers() variable
57 std::for_each(firstAddKeys.begin(), firstAddKeys.end(), [&firstAddUris](auto &result) { in AddObservers()
58 firstAddUris.emplace_back(result); in AddObservers()
60 if (firstAddUris.empty()) { in AddObservers()
65 auto subResults = proxy->SubscribeRdbData(firstAddUris, templateId, serviceCallback_); in AddObservers()
148 std::vector<std::string> firstAddUris;
149 std::for_each(firstAddKeys.begin(), firstAddKeys.end(), [&firstAddUris](auto &result) {
150 firstAddUris.emplace_back(result);
152 if (firstAddUris.empty()) {
155 auto subResults = proxy->EnableSubscribeRdbData(firstAddUris, templateI
[all...]

Completed in 2 milliseconds