[james-project] 02/06: JAMES-3028 read that returns InputStream is lazy, we must consume it to trigger the exception

[matthieu]

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

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

commit 5dc55b54bc6b3f1e088785689b7c0040edf6539d
Author: Matthieu Baechler <matth...@apache.org>
AuthorDate: Thu Jan 16 10:56:13 2020 +0100

    JAMES-3028 read that returns InputStream is lazy, we must consume it to 
trigger the exception
---
 .../java/org/apache/james/blob/api/BucketDumbBlobStoreContract.java   | 4 ++--
 .../java/org/apache/james/blob/api/DeleteDumbBlobStoreContract.java   | 2 +-
 .../java/org/apache/james/blob/api/ReadSaveDumbBlobStoreContract.java | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/server/blob/blob-api/src/test/java/org/apache/james/blob/api/BucketDumbBlobStoreContract.java
 
b/server/blob/blob-api/src/test/java/org/apache/james/blob/api/BucketDumbBlobStoreContract.java
index cbf8543..2a7fbae 100644
--- 
a/server/blob/blob-api/src/test/java/org/apache/james/blob/api/BucketDumbBlobStoreContract.java
+++ 
b/server/blob/blob-api/src/test/java/org/apache/james/blob/api/BucketDumbBlobStoreContract.java
@@ -54,7 +54,7 @@ public interface BucketDumbBlobStoreContract {
         store.save(TEST_BUCKET_NAME, TEST_BLOB_ID, SHORT_BYTEARRAY).block();
         store.deleteBucket(TEST_BUCKET_NAME).block();
 
-        assertThatThrownBy(() -> store.read(TEST_BUCKET_NAME, TEST_BLOB_ID))
+        assertThatThrownBy(() -> store.read(TEST_BUCKET_NAME, 
TEST_BLOB_ID).read())
             .isInstanceOf(ObjectNotFoundException.class);
     }
 
@@ -116,7 +116,7 @@ public interface BucketDumbBlobStoreContract {
         DumbBlobStore store = testee();
 
         store.save(TEST_BUCKET_NAME, TEST_BLOB_ID, SHORT_BYTEARRAY).block();
-        assertThatThrownBy(() -> store.read(CUSTOM_BUCKET_NAME, TEST_BLOB_ID))
+        assertThatThrownBy(() -> store.read(CUSTOM_BUCKET_NAME, 
TEST_BLOB_ID).read())
             .isInstanceOf(ObjectNotFoundException.class);
     }
 
diff --git 
a/server/blob/blob-api/src/test/java/org/apache/james/blob/api/DeleteDumbBlobStoreContract.java
 
b/server/blob/blob-api/src/test/java/org/apache/james/blob/api/DeleteDumbBlobStoreContract.java
index a391b90..5f1b0fa 100644
--- 
a/server/blob/blob-api/src/test/java/org/apache/james/blob/api/DeleteDumbBlobStoreContract.java
+++ 
b/server/blob/blob-api/src/test/java/org/apache/james/blob/api/DeleteDumbBlobStoreContract.java
@@ -70,7 +70,7 @@ public interface DeleteDumbBlobStoreContract  {
         store.save(TEST_BUCKET_NAME, TEST_BLOB_ID,  SHORT_BYTEARRAY).block();
         store.delete(TEST_BUCKET_NAME, TEST_BLOB_ID).block();
 
-        assertThatThrownBy(() -> store.read(TEST_BUCKET_NAME, TEST_BLOB_ID))
+        assertThatThrownBy(() -> store.read(TEST_BUCKET_NAME, 
TEST_BLOB_ID).read())
             .isInstanceOf(ObjectStoreException.class);
     }
 
diff --git 
a/server/blob/blob-api/src/test/java/org/apache/james/blob/api/ReadSaveDumbBlobStoreContract.java
 
b/server/blob/blob-api/src/test/java/org/apache/james/blob/api/ReadSaveDumbBlobStoreContract.java
index 820bd64..833dafd 100644
--- 
a/server/blob/blob-api/src/test/java/org/apache/james/blob/api/ReadSaveDumbBlobStoreContract.java
+++ 
b/server/blob/blob-api/src/test/java/org/apache/james/blob/api/ReadSaveDumbBlobStoreContract.java
@@ -172,7 +172,7 @@ public interface ReadSaveDumbBlobStoreContract {
     default void readStreamShouldThrowWhenNotExisting() {
         DumbBlobStore store = testee();
 
-        assertThatThrownBy(() -> store.read(TEST_BUCKET_NAME, new 
TestBlobId("unknown")))
+        assertThatThrownBy(() -> store.read(TEST_BUCKET_NAME, new 
TestBlobId("unknown")).read())
             .isInstanceOf(ObjectNotFoundException.class);
     }
 


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