Method pumpOrpcStream

vscode/src/extension.ts:1508–1551

(
    streamId: string,
    iterator: AsyncIterator<unknown>,
    controller: AbortController
  )

  }

  private async pumpOrpcStream(
    streamId: string,
    iterator: AsyncIterator<unknown>,
    controller: AbortController
  ): Promise<void> {
    try {
      for await (const value of {
        [Symbol.asyncIterator]() {
          return iterator;
        },
      } as AsyncIterable<unknown>) {
        if (controller.signal.aborted) {
          break;
        }

        this.postMessage({
          type: "orpcStreamData",
          streamId,
          value,
        });
      }

      this.postMessage({
        type: "orpcStreamEnd",
        streamId,
      });
    } catch (error) {
      if (controller.signal.aborted) {
        this.postMessage({
          type: "orpcStreamEnd",
          streamId,
        });
        return;
      }

      this.postMessage({
        type: "orpcStreamError",
        streamId,
        error: formatError(error),
      });
    } finally {
      this.activeOrpcStreams.delete(streamId);
    }
  }

  private async handleOrpcCall(args: {
    requestId: string;