Function pull

src/node/services/devToolsMiddleware.ts:660–701

(controller)

      const trackedStream = new ReadableStream<LanguageModelV3StreamPart>({
        async pull(controller): Promise<void> {
          try {
            for (;;) {
              const { done, value } = await reader.read();
              if (done) {
                await finalizeStep({
                  output: buildOutput(),
                  usage,
                  error: streamError,
                  rawRequest,
                  requestHeaders: capturedRequestHeaders,
                  responseHeaders,
                  rawResponse: fullStreamChunks,
                  rawChunks,
                });
                controller.close();
                return;
              }

              assert(value, "DevTools middleware expected stream value when done=false");

              if (!collectChunk(value)) {
                continue;
              }

              controller.enqueue(value);
              return;
            }
          } catch (error) {
            await finalizeStep({
              output: buildOutput(),
              usage,
              error: getErrorMessage(error),
              rawRequest,
              requestHeaders: capturedRequestHeaders,
              responseHeaders,
              rawResponse: fullStreamChunks,
              rawChunks,
            });
            controller.error(error);
          }
        },

        async cancel(reason): Promise<void> {
          try {