Function subscribeToStreams

src/debug/dart_debug_impl.ts:374–407

()

	}

	private async subscribeToStreams(): Promise<void> {
		if (!this.vmService)
			return;

		const serviceStreamName = this.vmServiceCapabilities.serviceStreamIsPublic ? "Service" : "_Service";
		await Promise.all([
			this.vmService.on("Isolate", (event: VMEvent) => this.handleIsolateEvent(event)),
			this.vmService.on("Debug", (event: VMEvent) => this.handleDebugEvent(event)),
			this.vmService.on(serviceStreamName, (event: VMEvent) => this.handleServiceEvent(event)),
		]);

		if (this.vmServiceCapabilities.hasLoggingStream && this.showDartDeveloperLogs) {
			await this.vmService.on("Logging", (event: VMEvent) => this.handleLoggingEvent(event)).catch((e) => {
				// For web, the protocol version says this is supported, but it throws.
				// TODO: Remove this catch block if/when the stable release does not throw.
				this.logger.info(errorString(e));
			});
		}

		// We don't know for certain we have a connected DDS that supports custom streams, so wrap in try/catch
		try {
			await this.vmService.on("ToolEvent", (event: VMEvent) => this.handleToolEvent(event)).catch((e) => {
				this.logger.info(errorString(e));
			});
		} catch (e) { }

		if (this.subscribeToStdout) {
			await this.vmService.on("Stdout", (event: VMWriteEvent) => this.handleStdoutEvent(event)).catch((e) => {
				// Some embedders may not provide Stdout and it's not clear if they will throw, so
				// just catch/log errors here.
				this.logger.info(errorString(e));
			});
		}
	}

	protected async terminate(force: boolean): Promise<void> {
		const signal = force ? "SIGKILL" : "SIGINT";