MCPcopy Create free account
hub / github.com/Houseofmvps/codesight / processQueue

Function processQueue

src/mcp-server.ts:724–736  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

722 }
723
724 async function processQueue() {
725 if (processing) return;
726 processing = true;
727 while (messageQueue.length > 0) {
728 const req = messageQueue.shift()!;
729 try {
730 await handleRequest(req);
731 } catch {
732 send({ jsonrpc: "2.0", id: null, error: { code: -32700, message: "Parse error" } });
733 }
734 }
735 processing = false;
736 }
737
738 process.stdin.setEncoding("utf-8");
739 process.stdin.on("data", (chunk: string) => {

Callers 1

startMCPServerFunction · 0.85

Calls 2

handleRequestFunction · 0.85
sendFunction · 0.85

Tested by

no test coverage detected