This is an automated email from the ASF dual-hosted git repository.

aduprat pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit 088123b1cc97da4b48bc277a04f27604971615be
Author: Gautier DI FOLCO <gdifo...@linagora.com>
AuthorDate: Tue Jul 2 11:33:56 2019 +0200

    fixup! Avoid blob copy when saving byte arrays
---
 .../org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/server/blob/blob-objectstorage/src/main/java/org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java
 
b/server/blob/blob-objectstorage/src/main/java/org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java
index c38ea12..c80f23e 100644
--- 
a/server/blob/blob-objectstorage/src/main/java/org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java
+++ 
b/server/blob/blob-objectstorage/src/main/java/org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java
@@ -134,9 +134,8 @@ public class ObjectStorageBlobsDAO implements BlobStore {
             .then(Mono.fromCallable(() -> 
blobIdFactory.from(hashingInputStream.hash().toString())));
     }
 
-    private Mono<String> save(BucketName bucketName, Blob blob) {
-        String containerName = this.containerName.value();
-        return Mono.fromCallable(() -> blobStore.putBlob(containerName, blob));
+    private Mono<Void> save(BucketName bucketName, Blob blob) {
+        return Mono.fromRunnable(() -> putBlobFunction.putBlob(blob));
     }
 
     @Override


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org

Reply via email to