Merge pull request #197 from cakofony/throw_on_failure

When InputStream reads fail, propagate the exception
RuedigerMoeller · Jun 19, 2017 · b7b3410 · b7b3410
2 parents 469d4c0 + 9488050
commit b7b3410
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/org/nustaq/serialization/util/FSTInputStream.java b/src/main/java/org/nustaq/serialization/util/FSTInputStream.java
@@ -84,9 +84,9 @@ public void readNextChunk(InputStream in) {
             } else {
                 fullyRead = true;
             }
-        } catch (Exception iex) {
-            LOGGER.log(FSTLogger.Level.ERROR, "Failed to read next chunk, assuming fully read", iex);
-            fullyRead = true;
+        } catch (IOException e) {
+            LOGGER.log(FSTLogger.Level.ERROR, "Failed to read next chunk from InputStream", e);
+            throw new RuntimeException("Failed to read next chunk from InputStream", e);
         }
     }