diff --git a/api/resolvers.mjs b/api/resolvers.mjs
index 4af9fdf..4106c9a 100644
--- a/api/resolvers.mjs
+++ b/api/resolvers.mjs
@@ -26,8 +26,9 @@ const storeFS = ({ stream, filename }) => {
           fs.unlinkSync(path)
         reject(error)
       })
-      .on('end', () => resolve({ id, path }))
       .pipe(fs.createWriteStream(path))
+      .on('error', error => reject(error))
+      .on('finish', () => resolve({ id, path }))
   )
 }