MCPcopy Create free account
hub / github.com/MemTensor/MemOS / broadcastPPSSE

Method broadcastPPSSE

packages/memos-core/src/viewer/server.ts:4797–4802  ·  view source on GitHub ↗
(event: string, data: unknown)

Source from the content-addressed store, hash-verified

4795 }
4796
4797 private broadcastPPSSE(event: string, data: unknown): void {
4798 const payload = `event: ${event}\ndata: ${JSON.stringify(data)}\n\n`;
4799 for (const c of this.ppSSEClients) {
4800 try { c.write(payload); } catch { /* */ }
4801 }
4802 }
4803
4804 private async runPostprocess(
4805 send: (event: string, data: unknown) => void,

Callers 2

sendMethod · 0.95
handlePostprocessMethod · 0.95

Calls 1

writeMethod · 0.65

Tested by

no test coverage detected