Function attachStream

src/utils/command.ts:144–179

(
      stream: NodeJS.ReadableStream | null | undefined,
      onChunk: (chunk: string) => void,
    )

    };

    const attachStream = (
      stream: NodeJS.ReadableStream | null | undefined,
      onChunk: (chunk: string) => void,
    ): void => {
      if (!stream) {
        return;
      }

      openStreamCount += 1;
      let streamClosed = false;

      const markClosed = (): void => {
        if (streamClosed) {
          return;
        }
        streamClosed = true;
        openStreamCount = Math.max(0, openStreamCount - 1);
        maybeSettleAfterExit();
      };

      const handleData = (data: Buffer | string): void => {
        if (settled) {
          return;
        }
        const chunk = data.toString();
        onChunk(chunk);
      };

      stream.on('data', handleData);
      stream.once('end', markClosed);
      stream.once('close', markClosed);
      streamClosers.push(markClosed);
      streamDetachers.push(() => {
        stream.off('data', handleData);
      });
    };

    if (detached) {
      let resolved = false;