Add clause to handle potential error return.

And update to 1.7.1
rabbitmq · Dec 4, 2023 · 9f8bfc9 · 9f8bfc9
1 parent 7f6d8e6
commit 9f8bfc9
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/MODULE.bazel b/MODULE.bazel
@@ -1,6 +1,6 @@
 module(
     name = "rabbitmq_osiris",
-    version = "1.7.0",
+    version = "1.7.1",
 )
 
 bazel_dep(

diff --git a/Makefile b/Makefile
@@ -1,6 +1,6 @@
 PROJECT = osiris
 PROJECT_DESCRIPTION = Foundation of the log-based streaming subsystem for RabbitMQ
-PROJECT_VERSION = 1.7.0
+PROJECT_VERSION = 1.7.1
 
 define PROJECT_ENV
 [

diff --git a/src/osiris_log.erl b/src/osiris_log.erl
@@ -1560,7 +1560,9 @@ read_chunk_parsed(#?MODULE{mode = #read{}} = State0,
             {Records, State1};
         {ok, Header, I0, State1} when HeaderOrNot == with_header ->
             Records = iter_all_records(iterator_next(I0), []),
-            {ok, Header, Records, State1}
+            {ok, Header, Records, State1};
+        Err ->
+            Err
     end.
 
 iter_all_records(end_of_chunk, Acc) ->