Function sendRequest

src/shared/services/stdio_service.ts:108–128

(method: string, params?: TReq)

	protected notifyRequestAfterExit() { }

	protected sendRequest<TReq, TResp>(method: string, params?: TReq): Promise<TResp> {
		// Generate an ID for this request so we can match up the response.
		const id = this.nextRequestID++;

		return new Promise<TResp>((resolve, reject) => {
			if (this.processExited) {
				this.notifyRequestAfterExit();
				reject(`Tried to call "${method}" but process has already exited with code ${this.process?.exitCode}`);
				return;
			}

			// Stash the callbacks so we can call them later.
			this.activeRequests[id.toString()] = [resolve, reject, method];

			const req = this.buildRequest(id, method, params);
			const json = this.messagesWrappedInBrackets
				? "[" + JSON.stringify(req) + "]\r\n"
				: JSON.stringify(req) + "\r\n";
			this.sendMessage(json);
		});
	}

	public cancelAllRequests() {
		// TODO(dantup): Consider/test rejecting all active requests?