Merge branch 'master' into DirectKafkaIntegration

vostok · Jul 4, 2024 · 2c67b6e · 2c67b6e
2 parents 028a110 + ac4480e
commit 2c67b6e
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,7 @@
+## 2.0.3 (11-12-2023):
+
+Add null check in `StreamBinaryEventsWriter.FlushAsync` to prevent NRE if there were no calls to `Put`
+
 ## 2.0.2 (29-11-2022):
 
 StreamConsumer: added supports for recall RunAsync method after cancellation

diff --git a/Vostok.Hercules.Consumers/StreamBinaryEventsWriter.cs b/Vostok.Hercules.Consumers/StreamBinaryEventsWriter.cs
@@ -70,6 +70,9 @@ public void Put(Action<IHerculesEventBuilder> buildEvent)
         // note (kungurtsev, 15.08.2022): do not call concurrently with Put
         public async Task FlushAsync()
         {
+            if (writer is null)
+                return;
+
             await FlushWriter(writer);
             writer = ObtainEmptyWriter();
         }

diff --git a/Vostok.Hercules.Consumers/Vostok.Hercules.Consumers.csproj b/Vostok.Hercules.Consumers/Vostok.Hercules.Consumers.csproj
@@ -7,7 +7,7 @@
     <Configurations>Debug;Release</Configurations>
   </PropertyGroup>
   <PropertyGroup>
-    <VersionPrefix>2.0.3</VersionPrefix>
+    <VersionPrefix>2.0.4</VersionPrefix>
   </PropertyGroup>
   <PropertyGroup>
     <Title>Vostok.Hercules.Consumers</Title>