jest

elastic · Nov 22, 2020 · 3fcac6e · 3fcac6e
1 parent e9103b7
commit 3fcac6e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/plugins/bfetch/public/batching/create_streaming_batched_function.ts b/src/plugins/bfetch/public/batching/create_streaming_batched_function.ts
@@ -107,7 +107,11 @@ export const createStreamingBatchedFunction = <Payload, Result extends object>(
               resolve();
               cleanup();
             };
-            if (abortPromise) abortPromise.catch(onDone);
+            if (abortPromise)
+              abortPromise.catch(() => {
+                item.future.reject(new AbortError());
+                onDone();
+              });
             item.future.promise.then(onDone, onDone);
           });
         });