File tree Expand file tree Collapse file tree 3 files changed +14
-11
lines changed
Firestore/core/src/firebase/firestore/core Expand file tree Collapse file tree 3 files changed +14
-11
lines changed Original file line number Diff line number Diff line change @@ -67,7 +67,7 @@ class EventManager : public SyncEngineCallback {
67
67
// Implements `SyncEngineCallback`.
68
68
void HandleOnlineStateChange (model::OnlineState online_state) override ;
69
69
void OnViewSnapshots (std::vector<core::ViewSnapshot>&& snapshots) override ;
70
- void OnError (const core::Query& query, util::Status error) override ;
70
+ void OnError (const core::Query& query, const util::Status& error) override ;
71
71
72
72
private:
73
73
/* *
Original file line number Diff line number Diff line change 95
95
}
96
96
}
97
97
98
- void EventManager::OnError (const core::Query& query, util::Status error) {
98
+ void EventManager::OnError (const core::Query& query,
99
+ const util::Status& error) {
99
100
auto found_iter = queries_.find (query);
100
- if (found_iter != queries_.end ()) {
101
- QueryListenersInfo& query_info = found_iter->second ;
102
- for (const auto & listener : query_info.listeners ) {
103
- listener->OnError (std::move (error));
104
- }
101
+ if (found_iter == queries_.end ()) {
102
+ return ;
103
+ }
105
104
106
- // Remove all listeners. NOTE: We don't need to call [FSTSyncEngine
107
- // stopListening] after an error.
108
- queries_. erase (found_iter );
105
+ QueryListenersInfo& query_info = found_iter-> second ;
106
+ for ( const auto & listener : query_info. listeners ) {
107
+ listener-> OnError (error );
109
108
}
109
+
110
+ // Remove all listeners. NOTE: We don't need to call [FSTSyncEngine
111
+ // stopListening] after an error.
112
+ queries_.erase (found_iter);
110
113
}
111
114
112
115
} // namespace core
Original file line number Diff line number Diff line change @@ -39,7 +39,7 @@ class SyncEngineCallback {
39
39
/* * Handles new view snapshots. */
40
40
virtual void OnViewSnapshots (std::vector<core::ViewSnapshot>&& snapshots) = 0;
41
41
/* * Handles the failure of a query. */
42
- virtual void OnError (const core::Query& query, util::Status error) = 0;
42
+ virtual void OnError (const core::Query& query, const util::Status& error) = 0;
43
43
};
44
44
45
45
} // namespace core
You can’t perform that action at this time.
0 commit comments