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>