demo.ts

// shared
export const debuggerProxyContract = contract({
	server: {
		keepAlive: notificationContract({}),
	},
	client: {
		serverStarted: notificationContract({ params: type({ port: number }) }),
		clientConnected: notificationContract({}),
	},
});

// client
const proc = spawn("node", ["server.js"]);
const { server } = debuggerProxyContract.getServerFromStream(
	NodeJsMessageStream.connectToProcess(proc),
	undefined,
	{
		serverStarted: ({ port }) => {
			// ...
		},
		clientConnected: () => {
			// ...
		}
	}
);

// server
const { client } = debuggerProxyContract.registerServerToStream(
	NodeJsMessageStream.connectToThisProcess(),
	{
		keepAlive: () => {
			timeout.reset();
		},
	}
);