summaryrefslogtreecommitdiffstats
path: root/common/pipeline.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r--common/pipeline.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index 1d45340..ce864f7 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -233,7 +233,7 @@ KAsync::Job<qint64> Pipeline::newEntity(void const *command, size_t size)
233 233
234 d->storeNewRevision(newRevision, fbb, bufferType, key); 234 d->storeNewRevision(newRevision, fbb, bufferType, key);
235 235
236 return KAsync::start<qint64>([newRevision]() { return newRevision; }); 236 return KAsync::value(newRevision);
237} 237}
238 238
239KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) 239KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size)
@@ -346,7 +346,7 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size)
346 adaptorFactory->createBuffer(newAdaptor, fbb, metadataFbb.GetBufferPointer(), metadataFbb.GetSize()); 346 adaptorFactory->createBuffer(newAdaptor, fbb, metadataFbb.GetBufferPointer(), metadataFbb.GetSize());
347 347
348 d->storeNewRevision(newRevision, fbb, bufferType, key); 348 d->storeNewRevision(newRevision, fbb, bufferType, key);
349 return KAsync::start<qint64>([newRevision]() { return newRevision; }); 349 return KAsync::value(newRevision);
350} 350}
351 351
352KAsync::Job<qint64> Pipeline::deletedEntity(void const *command, size_t size) 352KAsync::Job<qint64> Pipeline::deletedEntity(void const *command, size_t size)
@@ -433,7 +433,7 @@ KAsync::Job<qint64> Pipeline::deletedEntity(void const *command, size_t size)
433 processor->deletedEntity(key, newRevision, *current, d->transaction); 433 processor->deletedEntity(key, newRevision, *current, d->transaction);
434 } 434 }
435 435
436 return KAsync::start<qint64>([newRevision]() { return newRevision; }); 436 return KAsync::value(newRevision);
437} 437}
438 438
439void Pipeline::cleanupRevision(qint64 revision) 439void Pipeline::cleanupRevision(qint64 revision)