subscriptions

关于 subscriptions

使用异步生成器订阅 .subscription(async function*() { yield }) 设置实时事件流。推荐使用通过 httpSubscriptionLink 的 SSE，而非 WebSocket。使用 @trpc/server 的 tracked(id, data) 进行带 lastEventId 的重连恢复。WebSocket 通过 wsLink 和 @trpc/client 的 createWSClient，以及 @trpc/server/adapters/ws 的 applyWSSHandler。通过 initTRPC.create({ sse: { ping: { enabled, intervalMs } } }) 配置 SSE ping。通过 opts.signal 使用 AbortSignal 进行清理。使用 splitLink 路由订阅。