Ported to the kasync revamp

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)
 
     d->storeNewRevision(newRevision, fbb, bufferType, key);
 
-    return KAsync::start<qint64>([newRevision]() { return newRevision; });
+    return KAsync::value(newRevision);
 }
 
 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)
     adaptorFactory->createBuffer(newAdaptor, fbb, metadataFbb.GetBufferPointer(), metadataFbb.GetSize());
 
     d->storeNewRevision(newRevision, fbb, bufferType, key);
-    return KAsync::start<qint64>([newRevision]() { return newRevision; });
+    return KAsync::value(newRevision);
 }
 
 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)
         processor->deletedEntity(key, newRevision, *current, d->transaction);
     }
 
-    return KAsync::start<qint64>([newRevision]() { return newRevision; });
+    return KAsync::value(newRevision);
 }
 
 void Pipeline::cleanupRevision(qint64 revision)