Added `Define.TaskSeqField` for lazy async collection streaming support (`IAsyncEnumerable`) - #607

Merged

xperiandri merged 21 commits into

devfrom

task-seq-field-core

Sep 18, 2026

Commits on Sep 18, 2026

Added `Define.TaskSeqField` with streaming of `IAsyncEnumerable` results

xperiandri
and
claude
committed
12002df
Changed `BufferedStreamOptions` and stream helpers to use `voption`

xperiandri
and
claude
committed
1be63d3
Rewrote subscription disposal tests as asynchronous `task` tests

xperiandri
and
claude
committed
8d3ac42
Addressed Copilot review: ordered stream failures, bounded concurrency, lazy batching

xperiandri
and
claude
committed
18479a9
Addressed second Copilot review: enumerator lifecycle, WS partial data, subscription race

xperiandri
and
claude
committed
940686b
Moved the shared TaskSeq test sources into Helpers

xperiandri
and
claude
committed
5628275
Addressed third Copilot review: in-flight tracking, slot release on failure, placeholder cleanup

xperiandri
and
claude
committed
5520935
Fixed CI: the observer-throws regression test deadlocked on System.Reactive's own subscription teardown

xperiandri
and
claude
committed
5970b3b
Rechecked stop conditions after acquiring a concurrency slot

xperiandri
and
claude
committed
9c5c73d
Addressed sixth Copilot review: recheck after MoveNextAsync, clarified item-error semantics

xperiandri
and
claude
committed
43f363f
Addressed seventh Copilot review: addressable batch payloads, complete after Direct/RequestError

xperiandri
and
claude
committed
3b5d8ca
Addressed eighth Copilot review: WS error message, internal helper, conventions

xperiandri
and
claude
committed
156e149
Addressed ninth Copilot review: a failed non-null root field is an execution result, not a request error

xperiandri
and
claude
committed
7aaa5d1
Fix ninth-round regression: inline argument coercion must stay a RequestError

xperiandri
and
claude
committed
aa97285
Add regression coverage for a mixed success/error stream batch

xperiandri
and
claude
committed
be2b892
Streamline streaming execution: struct tuples, backgroundTask, renamed AsyncEnumerable module

xperiandri
and
claude
committed
46809e6
PR review fix
xperiandri
committed
25fbbbc
Address PR review feedback

Copilot
and
xperiandri
committed
9a926ff
Cancel MoveNextAsync on resolution failure

Copilot
and
xperiandri
authored
2693a4c
Prefer resolution failure over cancellation

Copilot
and
xperiandri
authored
cb67b78
Use `CanceledIndependently` active pattern
xperiandri
committed
34023fb

Navigation Menu

Added `Define.TaskSeqField` for lazy async collection streaming support (`IAsyncEnumerable`) - #607

Added `Define.TaskSeqField` for lazy async collection streaming support (`IAsyncEnumerable`)#607
xperiandri merged 21 commits into
devfrom
task-seq-field-core

Commits on Sep 18, 2026

Added `Define.TaskSeqField` with streaming of `IAsyncEnumerable` results

Changed `BufferedStreamOptions` and stream helpers to use `voption`

Rewrote subscription disposal tests as asynchronous `task` tests

Addressed Copilot review: ordered stream failures, bounded concurrency, lazy batching

Addressed second Copilot review: enumerator lifecycle, WS partial data, subscription race

Moved the shared TaskSeq test sources into Helpers

Addressed third Copilot review: in-flight tracking, slot release on failure, placeholder cleanup

Fixed CI: the observer-throws regression test deadlocked on System.Reactive's own subscription teardown

Rechecked stop conditions after acquiring a concurrency slot

Addressed sixth Copilot review: recheck after MoveNextAsync, clarified item-error semantics

Addressed seventh Copilot review: addressable batch payloads, complete after Direct/RequestError

Addressed eighth Copilot review: WS error message, internal helper, conventions

Addressed ninth Copilot review: a failed non-null root field is an execution result, not a request error

Fix ninth-round regression: inline argument coercion must stay a RequestError

Add regression coverage for a mixed success/error stream batch

Streamline streaming execution: struct tuples, backgroundTask, renamed AsyncEnumerable module

PR review fix

Address PR review feedback

Cancel MoveNextAsync on resolution failure

Prefer resolution failure over cancellation

Use `CanceledIndependently` active pattern