diff --git a/src/fetch.ts b/src/fetch.ts index 162ea45..d3dc106 100644 --- a/src/fetch.ts +++ b/src/fetch.ts @@ -64,6 +64,10 @@ export function fetchEventSource(input: RequestInfo, { fetch: inputFetch, ...rest }: FetchEventSourceInit) { + // Request leak if input signal aborted before the subscription even started. + if (inputSignal?.aborted) { + return; + } return new Promise((resolve, reject) => { // make a copy of the input headers since we may modify it below: const headers = { ...inputHeaders };