capnweb-based RPC wire types and server/client helpers shared between the DO and wsd. The package is split into four entry points:

• . — the typed wire interface (SyncRPC, ShellRPC, WorkspaceRPC, WireError).
• ./server — a Database-backed implementation. Imported by DO code and by the in-container workspace-server.
• ./client — typed stubs over a WebSocket carrier.
• ./driver — pullOnce / pushOnce / tick helpers that drive a SyncRPC client through a sync round.
• ./debug — leak-discovery helpers (stubSnapshot, enableStubTracking, isStubTrackingEnabled).

The driver helpers (pullOnce, pushOnce) handle disposal of capnweb result envelopes internally — callers that use them don't have to think about it.

Callers that reach into client.sync / client.shell directly to invoke streaming methods (fetchChanges, fetchObjects, shell.exec, shell.getExec) inherit the disposal contract. Either bind the awaited result to a using variable, or call result[Symbol.dispose]() after draining the stream.

The closing path on createSyncClient / createWorkspaceClient already disposes the root stub before tearing down the underlying WebSocket; calling client.close() is enough.

See docs/11_lifecycle.md for the full contract.

import {
  enableStubTracking,
  isStubTrackingEnabled,
  stubSnapshot,
} from "@cloudflare/workspace-rpc/debug";

// Either set CAPNWEB_TRACK_STUBS=1 in the environment, or call
// enableStubTracking() at module init in runtimes (like workerd)
// that don't surface env vars on process.env or globalThis.
enableStubTracking();

// Per-class live counter for every RpcTarget this package owns.
console.log(stubSnapshot());

The counter is opt-in and has no cost when disabled. wsd exposes the snapshot at GET /__wsd/stubs when tracking is on.