diff --git a/src/streaming.ts b/src/streaming.ts index 1176a580..d74c457e 100644 --- a/src/streaming.ts +++ b/src/streaming.ts @@ -12,9 +12,14 @@ type ServerSentEvent = { }; export class Stream implements AsyncIterable { + controller: AbortController; + + private response: Response; private decoder: SSEDecoder; - constructor(private response: Response, private controller: AbortController) { + constructor(response: Response, controller: AbortController) { + this.response = response; + this.controller = controller; this.decoder = new SSEDecoder(); }