refactor(utils/stream): stream pull (#2057)

honojs · Jan 23, 2024 · 0802633 · 0802633
1 parent 45d612d
commit 0802633
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/deno_dist/utils/stream.ts b/deno_dist/utils/stream.ts
@@ -15,11 +15,7 @@ export class StreamingApi {
     this.responseReadable = new ReadableStream({
       async pull(controller) {
         const { done, value } = await reader.read()
-        if (done) {
-          controller.close()
-        } else {
-          controller.enqueue(value)
-        }
+        done ? controller.close() : controller.enqueue(value)
       },
       cancel: () => {
         this.abortSubscribers.forEach((subscriber) => subscriber())

diff --git a/src/utils/stream.ts b/src/utils/stream.ts
@@ -15,11 +15,7 @@ export class StreamingApi {
     this.responseReadable = new ReadableStream({
       async pull(controller) {
         const { done, value } = await reader.read()
-        if (done) {
-          controller.close()
-        } else {
-          controller.enqueue(value)
-        }
+        done ? controller.close() : controller.enqueue(value)
       },
       cancel: () => {
         this.abortSubscribers.forEach((subscriber) => subscriber())