Lines Matching refs:observer
128 void Context::AddObserver(std::shared_ptr<ICooperateObserver> observer)
130 CHKPV(observer);
131 observers_.insert(observer);
134 void Context::RemoveObserver(std::shared_ptr<ICooperateObserver> observer)
136 observers_.erase(observer);
272 return std::all_of(observers_.cbegin(), observers_.cend(), [](const auto &observer) {
273 return observer->IsAllowCooperate();
279 std::for_each(observers_.cbegin(), observers_.cend(), [&data](const auto &observer) {
280 return observer->OnStartCooperate(data);
286 std::for_each(observers_.cbegin(), observers_.cend(), [&data](const auto &observer) {
287 return observer->OnRemoteStartCooperate(data);
295 for (const auto &observer : observers_) {
297 [observer, remoteNetworkId = Peer(), cursorPos = NormalizedCursorPosition()] {
298 FI_HILOGI("Notify one observer of transition out");
299 CHKPV(observer);
300 observer->OnTransitionOut(remoteNetworkId, cursorPos);
309 for (const auto &observer : observers_) {
311 [observer, remoteNetworkId = Peer(), cursorPos = NormalizedCursorPosition()] {
312 FI_HILOGI("Notify one observer of transition in");
313 CHKPV(observer);
314 observer->OnTransitionIn(remoteNetworkId, cursorPos);
323 for (const auto &observer : observers_) {
325 [observer, remoteNetworkId = Peer(), cursorPos = NormalizedCursorPosition()] {
326 FI_HILOGI("Notify one observer of come back");
327 CHKPV(observer);
328 observer->OnBack(remoteNetworkId, cursorPos);
337 for (const auto &observer : observers_) {
339 [observer, networkId, cursorPos] {
340 FI_HILOGI("Notify one observer of relay cooperation");
341 CHKPV(observer);
342 observer->OnRelay(networkId, cursorPos);
351 for (const auto &observer : observers_) {
353 [observer, remoteNetworkId] {
354 FI_HILOGI("Notify one observer of device offline, remoteNetworkId:%{public}s",
356 CHKPV(observer);
357 observer->CloseDistributedFileConnection(remoteNetworkId);
366 for (const auto &observer : observers_) {
368 [observer] {
369 FI_HILOGI("Notify one observer of reset cooperation");
370 CHKPV(observer);
371 observer->OnReset();