diff --git a/src/stream.ts b/src/stream.ts
index 73b901c..075169a 100644
--- a/src/stream.ts
+++ b/src/stream.ts
@@ -57,7 +57,9 @@ export class ReadItemsCommandReadableStream<
       }
 
       this.finishPush()
-    })
+    }).catch((error) => {
+         this.destroy(error)
+      })
   }
 
   private finishPush() {