diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-12 11:45:15 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-12 11:45:15 +0100 |
commit | 7daeec83233c522980d5e477fee82045de57f77d (patch) | |
tree | 5e03d11d23c764eb03f27393fcc37c0529405e10 /common/pipeline.cpp | |
parent | af8baff21529b5bc47725da3e9e00ec81e5b6f1b (diff) | |
download | sink-7daeec83233c522980d5e477fee82045de57f77d.tar.gz sink-7daeec83233c522980d5e477fee82045de57f77d.zip |
syncThen is no longer necessary
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r-- | common/pipeline.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp index 4cb5f21..32f6454 100644 --- a/common/pipeline.cpp +++ b/common/pipeline.cpp | |||
@@ -279,7 +279,7 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) | |||
279 | 279 | ||
280 | SinkTraceCtx(d->logCtx) << "Moving entity to new resource " << newEntity.identifier() << newEntity.resourceInstanceIdentifier() << targetResource; | 280 | SinkTraceCtx(d->logCtx) << "Moving entity to new resource " << newEntity.identifier() << newEntity.resourceInstanceIdentifier() << targetResource; |
281 | auto job = TypeHelper<CreateHelper>{bufferType}.operator()<KAsync::Job<void>, ApplicationDomain::ApplicationDomainType&>(newEntity); | 281 | auto job = TypeHelper<CreateHelper>{bufferType}.operator()<KAsync::Job<void>, ApplicationDomain::ApplicationDomainType&>(newEntity); |
282 | job = job.syncThen<void>([this, current, isMove, targetResource, bufferType](const KAsync::Error &error) { | 282 | job = job.then([this, current, isMove, targetResource, bufferType](const KAsync::Error &error) { |
283 | if (!error) { | 283 | if (!error) { |
284 | SinkTraceCtx(d->logCtx) << "Move of " << current.identifier() << "was successfull"; | 284 | SinkTraceCtx(d->logCtx) << "Move of " << current.identifier() << "was successfull"; |
285 | if (isMove) { | 285 | if (isMove) { |