Add handling of unexpected end of data stream

Author: Wojciech Strzalka

CHANGELOG.md

@@ -1,5 +1,7 @@
 ## Unreleased
 
+- Java: Add handling of unexpected end of data stream [ISSUE#80](https://github.com/openstreetmap/OSM-binary/issues/80)
+
 ## Release notes for 1.6.0 (2024-12-10)
 
 - Java: Update to latest protoc and protobuf runtime versions [#84](https://github.com/openstreetmap/OSM-binary/pull/84)

resources/broken7000bytes.pbf

@@ -18,7 +18,6 @@ License, or (at your option) any later version.
 package crosby.binary.file;
 
 import java.io.Closeable;
-import java.io.EOFException;
 import java.io.IOException;
 import java.io.InputStream;
 
@@ -29,13 +28,14 @@ public BlockInputStream(InputStream input, BlockReaderAdapter adaptor) {
         this.adaptor = adaptor;
     }
 
-    public void process() throws IOException {
+    public void process() throws Exception {
       try {
-        while (true) {
+        while (input.available() > 0) {
           FileBlock.process(input, adaptor);
         }
-      } catch (EOFException e) {
         adaptor.complete();
+      } catch (Exception e) {
+        adaptor.failure(e);
       }
     }
 

src.java/crosby/binary/file/BlockInputStream.java

@@ -37,4 +37,6 @@ public interface BlockReaderAdapter {
 
     /** Called when the file is fully read. */
     void complete();
+
+    void failure(Exception e) throws Exception;
 }