Streamix 1.1.0

Streamix

Idiomatic reactive streams for .NET.

Streamix gives you a fluent, async-first stream model on top of IAsyncEnumerable<T> with explicit semantics for composition, concurrency, ordering, cancellation, and backpressure.

Installation

dotnet add package Streamix

What You Get

• Stream<T> for 0..N values and Single<T> for 0..1 values
• Fluent operators for filtering, mapping, flattening, timing, retries, and recovery
• Explicit concurrency and ordering control
• Cold streams by default, with hot-stream primitives such as Publish, Replay, and RefCount
• LINQ/query syntax support for the common sequential surface
• Interop with IAsyncEnumerable<T>, channels, and an optional AsyncRx.NET extensions package

Basic Example

await Stream.Range(1, 10)
    .Filter(x => x % 2 == 0)
    .Map(x => x * 10)
    .ForEachAsync(Console.WriteLine);

A Little More

var products =
    GetUser(id)                       // Single<User>
    .FlatMap(user => GetOrders(user)) // Stream<Order>
    .Map(o => o.Product);             // Stream<string>

Common patterns:

• Map / MapAwait / MapOrdered
• Filter / FilterAwait
• FlatMap / FlatMapAwait / FlatMapOrdered / ConcatMap
• ScopedAsync (Structured Concurrency)
• Publish / Replay / RefCount
• Retry / Timeout / OnErrorResume
• ToListAsync, CountAsync, FirstAsync, SingleAsync

Streamix keeps concurrency, ordering, hot/cold behavior, and backpressure explicit instead of implicit.

Observability and Debugging

The core package also includes lightweight DEVX operators for naming and inspecting pipelines:

• Named(string name) tags a stream or single for downstream diagnostics.
• Log() writes Next(...), Error(...), and Completed signals.
• Debug() emits the same signal shape to System.Diagnostics.Debug.
• Checkpoint(string name) adds timing markers around a stage.
• Trace() emits lifecycle signals such as Subscribe, Request(1), Next(...), Completed, Cancelled, and Dispose.

await Stream.Range(1, 10)
    .Named("Orders")
    .Log()
    .Filter(x => x % 2 == 0)
    .ForEachAsync(Console.WriteLine);

Use the repository docs for fuller signal semantics and examples.

Learn More

• Overview and package map: README.md
• Developer guide: GETTING-STARTED.md
• Architecture and design notes: ARCHITECTURE.md
• Repository: github.com/khurram-uworx/streamix

Status

Streamix is still early-stage, but this package README is intended to describe the shipped core surface only. Use the root repository README for the fuller product contract, roadmap, and release checklist.