👁 Image
Akka.Streams.TestKit 1.5.69

• .NETStandard 2.0

  • Akka.Streams (>= 1.5.69)
  • Akka.TestKit (>= 1.5.69)

• net10.0

  • Akka.Streams (>= 1.5.69)
  • Akka.TestKit (>= 1.5.69)

• net6.0

  • Akka.Streams (>= 1.5.69)
  • Akka.TestKit (>= 1.5.69)

Akka.NET v1.5.69 is a maintenance release with bug fixes for Akka.DistributedData state propagation, Akka.Core message rejection handling, and Akka.Streams tracing reliability and backpressure cancellation.

**Akka.Streams**
* [Fix: propagate trace context across the `.Async()` actor boundary](https://github.com/akkadotnet/akka.net/pull/8246) - Fixes [#8243](https://github.com/akkadotnet/akka.net/issues/8243): With stream tracing enabled, per-element trace context was dropped at the publisher/subscriber actor boundary introduced by `.Async()`, leaving downstream stages with no ambient `ActivityContext`. Trace context now flows correctly across fused interpreter shells.
* [Add `OfferAsync(T, CancellationToken)` to `ISourceQueue<T>`](https://github.com/akkadotnet/akka.net/pull/8248) — enables cancellation of backpressured pending offers without emitting the cancelled element.

**Akka.Streams Bug Fixes**
* [Fix: observe discarded stream task faults](https://github.com/akkadotnet/akka.net/pull/8242) - Fixes [#8241](https://github.com/akkadotnet/akka.net/issues/8241): Resolves a `NullReferenceException` in the `GraphInterpreter` when tracing across actor boundaries — the interpreter now safely handles null activity context references during stream teardown.

**Akka.Core**
* [Fix: `RejectOnType<TMessage>` should use `Rejection`, not `Failure`](https://github.com/akkadotnet/akka.net/pull/8231) - Fixes [#8231](https://github.com/akkadotnet/akka.net/issues/8231): `RejectOnType` now correctly wraps rejected messages as `Rejection` rather than throwing a `Failure`, matching the expected stream contract.

**Akka.DistributedData**
* [Fix: propagate full state after pruning](https://github.com/akkadotnet/akka.net/pull/8220) - Fixes [#8220](https://github.com/akkadotnet/akka.net/issues/8220): Resolves a bug where pruning could cause incomplete state propagation in `ORSet` and `LWWDictionary`, leading to data inconsistencies during node merges.

1 contributor since release 1.5.68

Akka.NET v1.5.68 is a maintenance release with bug fixes for Akka.IO TCP connection handling, Akka.Streams stream materialized task faults, and Akka.TestKit xUnit 3 parallel context management.

**Akka.IO Bug Fixes**

* [Fix: report `Tcp.CommandFailed` when a scheduled connect retry throws](https://github.com/akkadotnet/akka.net/pull/8214) - Fixes [#8195](https://github.com/akkadotnet/akka.net/issues/8195): On Linux, a dropped TCP connection could permanently stall the user actor — it never received `Tcp.Connected` or `Tcp.CommandFailed` because a `PlatformNotSupportedException` thrown during a scheduled connect retry was swallowed by the `HashedWheelTimerScheduler`. The retry is now scheduled as a `RetryConnect` self-message via `IWithTimers`, ensuring any exception is surfaced to the commander as `Tcp.CommandFailed` and the connection actor stops cleanly. The pending timer is also canceled automatically when the actor stops, removing a latent use-after-dispose bug.

**Akka.Streams Bug Fixes**

* [Fix: observe discarded stream task faults](https://github.com/akkadotnet/akka.net/pull/8212) - Fixes [#8209](https://github.com/akkadotnet/akka.net/issues/8209) and [#8210](https://github.com/akkadotnet/akka.net/issues/8210): `IgnoreSink`, `QueueSource`, and `LazySink` now observe their internal materialized `Task` faults, preventing them from surfacing later as `UnobservedTaskException` events on the thread pool.

**Akka.TestKit Bug Fixes**

* [Fix: wrap outer `SynchronizationContext` in `ActorCellKeepingSynchronizationContext`](https://github.com/akkadotnet/akka.net/pull/8182) - `ActorCellKeepingSynchronizationContext` now accepts an optional inner `SynchronizationContext` and delegates scheduling to it while wrapping callbacks with the cell-pinning window. This prevents test hangs in downstream consumers such as `Akka.Hosting.TestKit` whose async `IHost` lifecycle depends on xUnit v3's `MaxConcurrencySyncContext` scheduling.

1 contributor since release 1.5.67

| COMMITS | LOC+ | LOC- | AUTHOR |
| --- | --- | --- | --- |
| 3 | 476 | 119 | Aaron Stannard |

To see the full set of changes in Akka.NET v1.5.68, [click here](https://github.com/akkadotnet/akka.net/milestone/151?closed=1).