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

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

commit 6d646e73e6a6f0891ae74ceb72c10fbc78eb5ff9
Author: Tung Tran <vtt...@linagora.com>
AuthorDate: Thu Jun 8 16:26:40 2023 +0700

    Fix awssdk SdkClientException: Duplicate handler name: 
HttpStreamsClientHandler in S3BlobStoreDAOTest
---
 .../org/apache/james/blob/objectstorage/aws/S3BlobStoreDAOTest.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/server/blob/blob-s3/src/test/java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAOTest.java
 
b/server/blob/blob-s3/src/test/java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAOTest.java
index 5f19f46694..43b7cf7818 100644
--- 
a/server/blob/blob-s3/src/test/java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAOTest.java
+++ 
b/server/blob/blob-s3/src/test/java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAOTest.java
@@ -82,7 +82,8 @@ public class S3BlobStoreDAOTest implements 
BlobStoreDAOContract {
 
         final int count = 1500;
         Flux.range(0, count)
-            .flatMap(i -> store.save(TEST_BUCKET_NAME, new 
TestBlobId("test-blob-id-" + i), ByteSource.wrap(ELEVEN_KILOBYTES)))
+            .concatMap(i -> store.save(TEST_BUCKET_NAME, new 
TestBlobId("test-blob-id-" + i),
+                ByteSource.wrap(ELEVEN_KILOBYTES)))
             .blockLast();
 
         
assertThat(Flux.from(testee().listBlobs(TEST_BUCKET_NAME)).count().block())


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

Reply via email to