chore(client): handle expo fetch abort errors

chore: unknown commit message

Author: stainless-bot

src/client.ts

@@ -5,7 +5,7 @@ import type { HTTPMethod, PromiseOrValue, MergedRequestInit } from './internal/t
 import { uuid4 } from './internal/utils/uuid';
 import { validatePositiveInteger, isAbsoluteURL } from './internal/utils/values';
 import { sleep } from './internal/utils/sleep';
-import { castToError } from './internal/errors';
+import { castToError, isAbortError } from './internal/errors';
 import type { APIResponseProps } from './internal/parse';
 import { getPlatformHeaders } from './internal/detect-platform';
 import * as Shims from './internal/shims';
@@ -483,7 +483,7 @@ export class OpenAI {
       if (retriesRemaining) {
         return this.retryRequest(options, retriesRemaining);
       }
-      if (response.name === 'AbortError') {
+      if (isAbortError(response)) {
         throw new Errors.APIConnectionTimeoutError();
       }
       throw new Errors.APIConnectionError({ cause: response });

src/internal/errors.ts

@@ -2,8 +2,12 @@
 
 export function isAbortError(err: unknown) {
   return (
-    (err instanceof Error && err.name === 'AbortError') ||
-    (typeof err === 'object' && err && 'name' in err && (err as any).name === 'AbortError')
+    typeof err === 'object' &&
+    err !== null &&
+    // Spec-compliant fetch implementations
+    (('name' in err && (err as any).name === 'AbortError') ||
+      // Expo fetch
+      ('message' in err && String((err as any).message).includes('FetchRequestCanceledException')))
   );
 }
 

src/streaming.ts

@@ -3,6 +3,7 @@ import { type ReadableStream } from './internal/shim-types';
 import { makeReadableStream } from './internal/shims';
 import { LineDecoder } from './internal/decoders/line';
 import { ReadableStreamToAsyncIterable } from './internal/shims';
+import { isAbortError } from './internal/errors';
 
 import { APIError } from './error';
 
@@ -77,7 +78,7 @@ export class Stream<Item> implements AsyncIterable<Item> {
         done = true;
       } catch (e) {
         // If the user calls `stream.controller.abort()`, we should exit without throwing.
-        if (e instanceof Error && e.name === 'AbortError') return;
+        if (isAbortError(e)) return;
         throw e;
       } finally {
         // If the user `break`s, abort the ongoing request.
@@ -124,7 +125,7 @@ export class Stream<Item> implements AsyncIterable<Item> {
         done = true;
       } catch (e) {
         // If the user calls `stream.controller.abort()`, we should exit without throwing.
-        if (e instanceof Error && e.name === 'AbortError') return;
+        if (isAbortError(e)) return;
         throw e;
       } finally {
         // If the user `break`s, abort the ongoing request.
@@ -208,6 +209,14 @@ export async function* _iterSSEMessages(
 ): AsyncGenerator<ServerSentEvent, void, unknown> {
   if (!response.body) {
     controller.abort();
+    if (
+      typeof (globalThis as any).navigator !== 'undefined' &&
+      (globalThis as any).navigator.product === 'ReactNative'
+    ) {
+      throw new OpenAIError(
+        `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 OpenAIError(`Attempted to iterate over a response with no body`);
   }