feat(NMTPeer): add NMTPeer target — Peer, PeerListener, PeerDispatcher - #4

Merged

gradyzhuo merged 13 commits into

mainfrom

feature/nmtp-peer

Apr 11, 2026

Commits on Apr 11, 2026

refactor(NMTP): MatterStream — opaque AsyncSequence replaces AsyncStream<Matter> in NMTClient.pushes

gradyzhuo
and
claude
committed
4a7f3de
fix(NMTP): MatterStream — private storage, remove unused import, add unit tests

gradyzhuo
and
claude
committed
34fcef8
feat(NMTPeer): package setup — NMTPeer target, package-level PendingRequests

gradyzhuo
and
claude
committed
230aa7c
fix(NMTP): PendingRequests methods — package access for cross-target use
gradyzhuo
committed
800092b
feat(NMTPeer): Peer — connect, fire, request, incoming, close

gradyzhuo
and
claude
committed
3929b93
fix(NMTPeer): Peer — safe remoteAddress, private channel/pendingRequests, test quality

gradyzhuo
and
claude
committed
347aabb
feat(NMTPeer): PeerListener — bind, accept loop, PeerStream, close

gradyzhuo
and
claude
committed
928d233
fix(NMTPeer): PeerListener — handler-before-yield race, test cleanup, PeerStream package init

gradyzhuo
and
claude
committed
11e3572
feat(NMTPeer): PeerDispatcher — register, run, typed request<M,R>

gradyzhuo
and
claude
committed
3772bbd
fix(NMTPeer): PeerDispatcher — structured concurrency, reply type validation, import cleanup

gradyzhuo
and
claude
committed
ebe427f
feat(NMTPeer): PeerDispatcher factories — connect, listen; PeerDispatcherListener

gradyzhuo
and
claude
committed
ba83221
fix(NMTPeer): PeerDispatcherListener — self-removing task registry, package init, test cleanup

gradyzhuo
and
claude
committed
fe3e108
fix(NMTPeer): final review fixes — close() drains tasks before ELG shutdown, remove placeholders

gradyzhuo
and
claude
committed
1ef40c7

Navigation Menu

Uh oh!

feat(NMTPeer): add NMTPeer target — Peer, PeerListener, PeerDispatcher - #4

feat(NMTPeer): add NMTPeer target — Peer, PeerListener, PeerDispatcher#4
gradyzhuo merged 13 commits into
mainfrom
feature/nmtp-peer

Commits on Apr 11, 2026

refactor(NMTP): MatterStream — opaque AsyncSequence replaces AsyncStream<Matter> in NMTClient.pushes

fix(NMTP): MatterStream — private storage, remove unused import, add unit tests

feat(NMTPeer): package setup — NMTPeer target, package-level PendingRequests

fix(NMTP): PendingRequests methods — package access for cross-target use

feat(NMTPeer): Peer — connect, fire, request, incoming, close

fix(NMTPeer): Peer — safe remoteAddress, private channel/pendingRequests, test quality

feat(NMTPeer): PeerListener — bind, accept loop, PeerStream, close

fix(NMTPeer): PeerListener — handler-before-yield race, test cleanup, PeerStream package init

feat(NMTPeer): PeerDispatcher — register, run, typed request<M,R>

fix(NMTPeer): PeerDispatcher — structured concurrency, reply type validation, import cleanup

feat(NMTPeer): PeerDispatcher factories — connect, listen; PeerDispatcherListener

fix(NMTPeer): PeerDispatcherListener — self-removing task registry, package init, test cleanup

fix(NMTPeer): final review fixes — close() drains tasks before ELG shutdown, remove placeholders