fix(streaming): handle more AbortError cases

Author: RobertCraigie

packages/bedrock-sdk/src/streaming.ts

@@ -90,7 +90,7 @@ export class Stream<Item> extends CoreStream<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.
@@ -101,3 +101,14 @@ export class Stream<Item> extends CoreStream<Item> {
     return new Stream(iterator, controller);
   }
 }
+
+function isAbortError(err: unknown) {
+  return (
+    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/lib/MessageStream.ts

@@ -1,3 +1,4 @@
+import { isAbortError } from '../internal/errors';
 import { AnthropicError, APIUserAbortError } from '../error';
 import {
   type ContentBlock,
@@ -289,7 +290,7 @@ export class MessageStream implements AsyncIterable<MessageStreamEvent> {
 
   #handleError = (error: unknown) => {
     this.#errored = true;
-    if (error instanceof Error && error.name === 'AbortError') {
+    if (isAbortError(error)) {
       error = new APIUserAbortError();
     }
     if (error instanceof APIUserAbortError) {