Changeset View
Changeset View
Standalone View
Standalone View
src/akonadi/akonadilivequeryhelpers.cpp
| Show First 20 Lines • Show All 170 Lines • ▼ Show 20 Line(s) | 170 | { | |||
|---|---|---|---|---|---|
| 171 | auto storage = m_storage; | 171 | auto storage = m_storage; | ||
| 172 | return [storage, item] (const Domain::LiveQueryInput<Item>::AddFunction &add) { | 172 | return [storage, item] (const Domain::LiveQueryInput<Item>::AddFunction &add) { | ||
| 173 | auto job = storage->fetchItem(item); | 173 | auto job = storage->fetchItem(item); | ||
| 174 | Utils::JobHandler::install(job->kjob(), [storage, job, add] { | 174 | Utils::JobHandler::install(job->kjob(), [storage, job, add] { | ||
| 175 | if (job->kjob()->error() != KJob::NoError) | 175 | if (job->kjob()->error() != KJob::NoError) | ||
| 176 | return; | 176 | return; | ||
| 177 | 177 | | |||
| 178 | Q_ASSERT(job->items().size() == 1); | 178 | Q_ASSERT(job->items().size() == 1); | ||
| 179 | auto item = job->items()[0]; | 179 | auto item = job->items().at(0); | ||
| 180 | Q_ASSERT(item.parentCollection().isValid()); | 180 | Q_ASSERT(item.parentCollection().isValid()); | ||
| 181 | auto job = storage->fetchItems(item.parentCollection()); | 181 | auto job = storage->fetchItems(item.parentCollection()); | ||
| 182 | Utils::JobHandler::install(job->kjob(), [job, add] { | 182 | Utils::JobHandler::install(job->kjob(), [job, add] { | ||
| 183 | if (job->kjob()->error() != KJob::NoError) | 183 | if (job->kjob()->error() != KJob::NoError) | ||
| 184 | return; | 184 | return; | ||
| 185 | 185 | | |||
| 186 | foreach (const auto &item, job->items()) | 186 | foreach (const auto &item, job->items()) | ||
| 187 | add(item); | 187 | add(item); | ||
| Show All 16 Lines | |||||