fix(kurrentdb): bump KurrentDB.Client to 1.4.1 to stop unobserved read task exceptions

[Inok]

Problem

KurrentDBEventStore.ReadEvents and ReadEventsBackwards leaked an unobserved task exception whenever a read failed.

KurrentDBClient.ReadStreamAsync returns a ReadStreamResult that parks the read's failure in two places:

catch (Exception ex) {
    tcs.TrySetException(ex);            // the public ReadState task — nothing awaits it
    _channel.Writer.TryComplete(ex);    // the message channel — the enumerator observes this
}

Both read methods create that result, own it for its whole lifetime, and only call ToArrayAsync — so the faulted ReadState task is collected unobserved and surfaces on the finalizer thread as a TaskScheduler.UnobservedTaskException. (StreamExists in the same class already awaits ReadState, so it was never affected, and ReadAllStreamResult has no ReadState at all, so the $all paths were never affected either.)

The leak window is precisely "the read faults before the first response arrives" — once the first response lands, the pump has already called tcs.SetResult(ReadState.Ok) and the later TrySetException is a no-op. So this was never only about cancellation: connection failures, auth failures, deadline expiry and an unavailable server all leaked one unobserved exception per read.

Fix

Bump KurrentDB.Client to 1.4.1, which observes the fault at the source (client #423):

if (tcs.TrySetException(ex))
    _ = tcs.Task.Exception;

The same client release fixes two sibling sinks that a consumer cannot reach from the outside at all — SharingProvider's call-invoker boxes, and the batch appender's fire-and-forget send loop (which AppendToStreamAsync uses by default).

Verification

20 reads made to fault before the first response (client pointed at a closed port), counting TaskScheduler.UnobservedTaskException:

	1.4.0	1.4.1
unobserved exceptions	59	0

On 1.4.0 those 59 came from three distinct sinks: 18× RpcException(Cancelled) from ReadState, 21× RpcException(Unavailable) from SharingProvider retry boxes, 20× ObjectDisposedException from its disposed-box path.

Solution builds clean on net8.0/net9.0/net10.0.

Why no Eventuous-side guard as well

It was considered and deliberately left out. The only reliable placement is a continuation attached immediately after ReadStreamAsync returns, i.e. before the fault exists, which costs a continuation task allocation on every read — every aggregate load — to guard a case the client now handles at the source. The cheap conditional alternative does not work: _ = read.ReadState.Exception in a catch/finally misses the common cancellation case, because ToArrayAsync(ct) throws OperationCanceledException from the caller's token before the pump's catch runs, leaving the task incomplete and Exception null.

The version floor also carries weight: the package dependency becomes KurrentDB.Client >= 1.4.1, so landing back on 1.4.0 requires an explicit direct downgrade, which NuGet reports as NU1605.

🤖 Generated with Claude Code

[qodo-free-for-open-source-projects]

PR Summary by Qodo

Bump KurrentDB.Client to prevent unobserved read exceptions

🐞 Bug fix ⚙️ Configuration changes 🕐 Less than 5 minutes

AI Description

• Upgrades KurrentDB.Client from 1.4.0 to 1.4.1.
• Prevents failed reads from surfacing unobserved task exceptions during garbage collection.

High-Level Assessment

The dependency upgrade is the optimal approach because KurrentDB.Client 1.4.1 observes failures at their source and fixes additional internal exception sinks inaccessible to consumers. An Eventuous-side continuation was reasonably dismissed because it would add an allocation to every read and still could not address all client-internal sinks.

Files changed (1) +1 / -1

Bug fix (1) +1 / -1

Directory.Packages.propsUpgrade KurrentDB.Client to 1.4.1 +1/-1

Upgrade KurrentDB.Client to 1.4.1

• Raises the centrally managed KurrentDB.Client version from 1.4.0 to 1.4.1. The new minimum version prevents early read failures and related client-internal tasks from producing unobserved exceptions.

Directory.Packages.props

[qodo-free-for-open-source-projects]

Code Review by Qodo

🐞 Bugs (0) 📘 Rule violations (0) 📎 Requirement gaps (0)

Great, no issues found!

Qodo reviewed your code and found no material issues that require review

Tip of the day

💡 Did you know, you can show, collapse, or hide each part of a finding: code, evidence, and all

More tips ↗ | Customize Qodo ↗ | Qodo docs ↗

[github-actions]

Test Results

 46 files  + 24   46 suites  +24   12m 21s ⏱️ -10s
373 tests +  4  373 ✅ +  4  0 💤 ±0  0 ❌ ±0 
700 runs  +320  700 ✅ +320  0 💤 ±0  0 ❌ ±0 

Results for commit 5d1e269. ± Comparison against base commit 3cb68c2.

This pull request removes 5 and adds 9 tests. Note that renamed tests count towards both.

Eventuous.Tests.Azure.ServiceBus.IsSerialisableByServiceBus ‑ Passes(08/03/2026 14:31:31 +00:00)
Eventuous.Tests.Azure.ServiceBus.IsSerialisableByServiceBus ‑ Passes(08/03/2026 14:31:31)
Eventuous.Tests.Azure.ServiceBus.IsSerialisableByServiceBus ‑ Passes(d6ea070b-8d6b-46d6-9e04-bb9b4acedc59)
Eventuous.Tests.Subscriptions.SequenceTests ‑ ShouldReturnFirstBefore(CommitPosition { Position: 0, Sequence: 1, Timestamp: 2026-08-03T14:31:52.5505416+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-03T14:31:52.5505416+00:00 }, CommitPosition { Position: 0, Sequence: 4, Timestamp: 2026-08-03T14:31:52.5505416+00:00 }, CommitPosition { Position: 0, Sequence: 6, Timestamp: 2026-08-03T14:31:52.5505416+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-03T14:31:52.5505416+00:00 })
Eventuous.Tests.Subscriptions.SequenceTests ‑ ShouldReturnFirstBefore(CommitPosition { Position: 0, Sequence: 1, Timestamp: 2026-08-03T14:31:52.5505416+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-03T14:31:52.5505416+00:00 }, CommitPosition { Position: 0, Sequence: 6, Timestamp: 2026-08-03T14:31:52.5505416+00:00 }, CommitPosition { Position: 0, Sequence: 8, Timestamp: 2026-08-03T14:31:52.5505416+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-03T14:31:52.5505416+00:00 })

Eventuous.Tests.Azure.ServiceBus.IsSerialisableByServiceBus ‑ Passes(08/19/2026 15:40:05 +00:00)
Eventuous.Tests.Azure.ServiceBus.IsSerialisableByServiceBus ‑ Passes(08/19/2026 15:40:05)
Eventuous.Tests.Azure.ServiceBus.IsSerialisableByServiceBus ‑ Passes(f7942b43-560f-40a2-bcf5-ce6fffe160df)
Eventuous.Tests.Subscriptions.SequenceTests ‑ ShouldReturnFirstBefore(CommitPosition { Position: 0, Sequence: 1, Timestamp: 2026-08-19T15:35:44.8277351+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:35:44.8277351+00:00 }, CommitPosition { Position: 0, Sequence: 4, Timestamp: 2026-08-19T15:35:44.8277351+00:00 }, CommitPosition { Position: 0, Sequence: 6, Timestamp: 2026-08-19T15:35:44.8277351+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:35:44.8277351+00:00 })
Eventuous.Tests.Subscriptions.SequenceTests ‑ ShouldReturnFirstBefore(CommitPosition { Position: 0, Sequence: 1, Timestamp: 2026-08-19T15:35:44.8277351+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:35:44.8277351+00:00 }, CommitPosition { Position: 0, Sequence: 6, Timestamp: 2026-08-19T15:35:44.8277351+00:00 }, CommitPosition { Position: 0, Sequence: 8, Timestamp: 2026-08-19T15:35:44.8277351+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:35:44.8277351+00:00 })
Eventuous.Tests.Subscriptions.SequenceTests ‑ ShouldReturnFirstBefore(CommitPosition { Position: 0, Sequence: 1, Timestamp: 2026-08-19T15:35:53.7216170+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:35:53.7216170+00:00 }, CommitPosition { Position: 0, Sequence: 4, Timestamp: 2026-08-19T15:35:53.7216170+00:00 }, CommitPosition { Position: 0, Sequence: 6, Timestamp: 2026-08-19T15:35:53.7216170+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:35:53.7216170+00:00 })
Eventuous.Tests.Subscriptions.SequenceTests ‑ ShouldReturnFirstBefore(CommitPosition { Position: 0, Sequence: 1, Timestamp: 2026-08-19T15:35:53.7216170+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:35:53.7216170+00:00 }, CommitPosition { Position: 0, Sequence: 6, Timestamp: 2026-08-19T15:35:53.7216170+00:00 }, CommitPosition { Position: 0, Sequence: 8, Timestamp: 2026-08-19T15:35:53.7216170+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:35:53.7216170+00:00 })
Eventuous.Tests.Subscriptions.SequenceTests ‑ ShouldReturnFirstBefore(CommitPosition { Position: 0, Sequence: 1, Timestamp: 2026-08-19T15:36:02.2061247+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:36:02.2061247+00:00 }, CommitPosition { Position: 0, Sequence: 4, Timestamp: 2026-08-19T15:36:02.2061247+00:00 }, CommitPosition { Position: 0, Sequence: 6, Timestamp: 2026-08-19T15:36:02.2061247+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:36:02.2061247+00:00 })
Eventuous.Tests.Subscriptions.SequenceTests ‑ ShouldReturnFirstBefore(CommitPosition { Position: 0, Sequence: 1, Timestamp: 2026-08-19T15:36:02.2061247+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:36:02.2061247+00:00 }, CommitPosition { Position: 0, Sequence: 6, Timestamp: 2026-08-19T15:36:02.2061247+00:00 }, CommitPosition { Position: 0, Sequence: 8, Timestamp: 2026-08-19T15:36:02.2061247+00:00 }, CommitPosition { Position: 0, Sequence: 2, Timestamp: 2026-08-19T15:36:02.2061247+00:00 })