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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
