Fixed #

• pubspec.yaml: expanded description to satisfy pub.flutter-io.cn length checks.

Breaking #

• Select → XSelect
  • Select.any(...) removed. Use:
    • XSelect.run<T>((b) => b ... ) — async, waits for first ready arm.
    • XSelect.syncRun<T>((b) => b ... ) — non-blocking, returns immediately if an arm is ready.
    • XSelect.race<T>([ (b) => b.onFuture(...), ... ]) — race multiple builders.
    • XSelect.syncRace<T>([ ... ]) — non-blocking variant.
  • Builder API changes:
    • New onRecvValue(rx, onValue, onDisconnected: ...) when you only care about values.
    • New onTick(Ticker, ...) and timeout(duration, ...).
    • onStream, onFuture kept (signatures aligned).
  • Loop control: SelectDecision removed. Just return the value you want from the winning arm. If you used continueLoop/breakLoop, return a bool instead and branch on it.
• Property rename
  • Receiver.isClosed → Receiver.isDisconnected (and it’s available on all receivers, not just closable ones).
• Result helpers rename
  • SendResultX.isOk → hasSend
  • RecvResultX.isOk → hasValue
  • (Others kept: isFull, isDisconnected, isTimeout, isFailed, hasError, isEmpty, valueOrNull.)
• Low-level channel factory parameter rename
  • {Mpsc,Mpmc}.channel<T>(..., **dropPolicy**: ...) → {Mpsc,Mpmc}.channel<T>(..., **policy**: ...)
  • onDrop unchanged.
• SPSC constructor signature
  • Spsc.channel<T>(**capacityPow2:** 1024) → Spsc.channel<T>(1024) (positional power-of-two).
• MPMC send semantics clarified
  • Sending with no live receivers now returns SendErrorDisconnected immediately (enforced consistently across bounded/unbounded).

Added #

• Notify primitive:

  • notified() → (Future<void>, cancel) that consumes a permit if available, otherwise waits.
  • notifyOne() wakes one waiter or stores a permit; notifyAll() wakes all current waiters.
  • close() wakes waiters with disconnected.
  • epoch for tracing/tests.

• Uniform receiver capabilities:

  • recvCancelable() on all receivers.
  • isDisconnected property available on all receivers.

• Ticker

  • Ticker.every(Duration) with .reset(...) to integrate timed arms via onTick.

• Examples

  • example/ showcasing MPSC, MPMC, SPSC, OneShot, LatestOnly, and XSelect.

Changed #

• Select integration
  • XSelect now uses recvCancelable() under the hood for receivers; cancellation is best-effort where an implementation cannot immediately abort a pending wait.
• Unbounded buffers
  • Now chunked by default for throughput & GC friendliness:
    • Hot small ring + chunked overflow.
    • Tuned defaults (internal): hot=8192, chunk=4096, rebalanceBatch=64, threshold=cap/16, gate=chunk/2.
  • Mpsc.unbounded / Mpmc.unbounded accept chunked: true|false (default true).
• LatestOnly
  • Fast-path coalescing tightened; benches around ~110–140 Mops/s on common desktop VMs.
• Docs/README updated to XSelect.*, policy parameter, SPSC signature, isDisconnected, and universal recvCancelable().

Migration guide (0.6 → 0.7) #

- while (!rx.isClosed) {
+ while (!rx.isDisconnected) {
    // ...
  }

- final out = await Select.any((s) => s
-   ..onReceiver(rx, ok: (v) => SelectDecision.breakLoop)
-   ..onFuture(fut, (_) => SelectDecision.continueLoop));

+ final broke = await XSelect.run<bool>((s) => s
+   ..onRecvValue(rx, (v) => true, onDisconnected: () => true)
+   ..onFuture(fut, (_) => false));
+ if (broke) break;

- final (tx, rx) = Mpmc.channel<int>(capacity: 1024, dropPolicy: DropPolicy.oldest);
+ final (tx, rx) = Mpmc.channel<int>(capacity: 1024, policy: DropPolicy.oldest);

- final (tx, rx) = Spsc.channel<int>(capacityPow2: 1024);
+ final (tx, rx) = Spsc.channel<int>(1024);

- if ((await tx.send(v)).isOk) { ... }
+ if ((await tx.send(v)).hasSend) { ... }

- final r = await rx.recv(); if (r.isOk) use(r.valueOrNull);
+ final r = await rx.recv(); if (r.hasValue) use(r.valueOrNull!);

Added #

• Select:
  • Select.any((s) => s.onReceiver(...).onFuture(...).onStream(...).onTimer(...))
  • Each branch executes an async block, first to complete wins
  • Losing branch are properly cancelled (recvCancelable, stream cancel)
  • SelectDecision (continueLoop / breakLoop) for loop control
  • Added removeRecvWaiter to all buffers
  • New recvCancelable helper in ChannelOps

Added #

• Timeout helpers:
  • recvTimeout, sendTimeout
• Batch helpers :
  • sendAll, recvAll, trySendAll, tryRecvAll

Added #

• LatestOnly channels:
  • Mpsc and Mpmc latestOnly
• Semantics: new sends overwrite previous values

Added #

• Isolate adapters:
  • ReceivePort → Mpsc / Mpmc
  • Typed request/reply via SendPort.request
• Web adapters:
  • MessagePort → Mpsc / Mpmc
  • Typed requests with MessageChannel
• Stream adapters:
  • Receiver.toBroadcastStream, Stream.redirectToSender

Added #

• SPSC ring buffer:
  • Power-of-two capacity
  • Ultra-low overhead trySend, tryRecv
• OneShot channel:
  • consumeOnce=true: first receiver consumes and disconnects
  • consumeOnce=false: all receivers observe the same value
• Drop policies: block, oldest, newest
• Result extensions:
  • SendResultX (ok, full, disconnected)
  • RecvResultX (ok, empty, disconnected, valueOrNull)

Added #

• MPSC channels (multi-producer, single-consumer)
  • unbounded, bounded(capacity), rendezvous(cap=0)
• MPMC channels (multi-producer, multi-consumer)
  • unbounded, bounded(capacity)
• Core traits: ChannelCore, ChannelOps, ChannelLifecycle