diff options
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r-- | common/pipeline.cpp | 6 |
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 | ||
239 | KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) | 239 | KAsync::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 | ||
352 | KAsync::Job<qint64> Pipeline::deletedEntity(void const *command, size_t size) | 352 | KAsync::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 | ||
439 | void Pipeline::cleanupRevision(qint64 revision) | 439 | void Pipeline::cleanupRevision(qint64 revision) |