FM / decoders

/opt/canhelp/node_modules/@anthropic-ai/sdk/src/internal/decoders/

/opt/canhelp/node_modules/@anthropic-ai/sdk/src/internal/decoders

Name	Size	Mode	Actions
jsonl.ts	1509	0644	edit dl rm
line.ts	3888	0644	edit dl rm

Edit: /opt/canhelp/node_modules/@anthropic-ai/sdk/src/internal/decoders/jsonl.ts (1509B)

import { AnthropicError } from '../../core/error';
import { ReadableStreamToAsyncIterable } from '../shims';
import { LineDecoder, type Bytes } from './line';

export class JSONLDecoder<T> {
  controller: AbortController;

constructor(
    private iterator: AsyncIterableIterator<Bytes>,
    controller: AbortController,
  ) {
    this.controller = controller;
  }

private async *decoder(): AsyncIterator<T, any, undefined> {
    const lineDecoder = new LineDecoder();
    for await (const chunk of this.iterator) {
      for (const line of lineDecoder.decode(chunk)) {
        yield JSON.parse(line) as T;
      }
    }

for (const line of lineDecoder.flush()) {
      yield JSON.parse(line) as T;
    }
  }

[Symbol.asyncIterator](): AsyncIterator<T> {
    return this.decoder();
  }

static fromResponse<T>(response: Response, controller: AbortController): JSONLDecoder<T> {
    if (!response.body) {
      controller.abort();
      if (
        typeof (globalThis as any).navigator !== 'undefined' &&
        (globalThis as any).navigator.product === 'ReactNative'
      ) {
        throw new AnthropicError(
          `The default react-native fetch implementation does not support streaming. Please use expo/fetch: https://docs.expo.dev/versions/latest/sdk/expo/#expofetch-api`,
        );
      }
      throw new AnthropicError(`Attempted to iterate over a response with no body`);
    }

return new JSONLDecoder(ReadableStreamToAsyncIterable<Bytes>(response.body), controller);
  }
}

cmd: