v0.0.8

What's New

GroupBy Operator

Partitions observable streams into groups based on a key selector. Each group is a GroupedAsyncObservable<TKey, TValue> with a Key property.

var grouped = source.GroupBy(x => x % 2);

RefCountTable

Reference-counted resource manager for creating message hubs and preventing memory leaks. Resources are automatically cleaned up when all references are disposed.

var hub = RefCountTable.Create<string, ISubject<string>>(...);
await using var ref1 = await hub.GetOrCreateAsync("topic", ct);
var subject = ref1.Value;
// Automatic cleanup when last reference is disposed