1 files changed, 6 insertions, 4 deletions
diff --git a/storage/src/tests/persistence/filestorage/operationabortingtest.cpp b/storage/src/tests/persistence/filestorage/operationabortingtest.cpp
index c51357cacd1..07d2b24d536 100644
--- a/storage/src/tests/persistence/filestorage/operationabortingtest.cpp
+++ b/storage/src/tests/persistence/filestorage/operationabortingtest.cpp
@@ -46,14 +46,15 @@ public:
           _deleteBucketInvocations(0)
     {}
 
-    spi::Result put(const spi::Bucket&, spi::Timestamp, document::Document::SP, spi::Context&) override
+    void
+    putAsync(const spi::Bucket&, spi::Timestamp, document::Document::SP, spi::Context&, spi::OperationComplete::UP onComplete) override
     {
         _queueBarrier.await();
         // message abort stage with active opertion in disk queue
         std::this_thread::sleep_for(75ms);
         _completionBarrier.await();
         // test finished
-        return spi::Result();
+        onComplete->onComplete(std::make_unique<spi::Result>());
     }
 
     spi::BucketInfoResult getBucketInfo(const spi::Bucket& bucket) const override {
@@ -66,9 +67,10 @@ public:
         return PersistenceProviderWrapper::createBucket(bucket, ctx);
     }
 
-    spi::Result deleteBucket(const spi::Bucket& bucket, spi::Context& ctx) override {
+    void
+    deleteBucketAsync(const spi::Bucket& bucket, spi::Context& ctx, spi::OperationComplete::UP onComplete) override {
         ++_deleteBucketInvocations;
-        return PersistenceProviderWrapper::deleteBucket(bucket, ctx);
+        PersistenceProviderWrapper::deleteBucketAsync(bucket, ctx, std::move(onComplete));
     }
 };