abort live streams using true instead of error

ssbc · Jun 28, 2022 · 869133a · 869133a
1 parent ff6d8eb
commit 869133a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 7 deletions.
diff --git a/errors.js b/errors.js
@@ -42,10 +42,6 @@ function appendLargerThanBlockErr() {
   return new Error('Data to be appended is larger than block size')
 }
 
-function streamClosedErr() {
-  return new Error('async-append-only-log stream is closed')
-}
-
 function appendTransactionWantsArrayErr() {
   return new Error('appendTransaction expects first argument to be an array')
 }
@@ -66,7 +62,6 @@ module.exports = {
   deletedRecordErr,
   delDuringCompactErr,
   appendLargerThanBlockErr,
-  streamClosedErr,
   appendTransactionWantsArrayErr,
   unexpectedTruncationErr,
 }
diff --git a/index.js b/index.js
@@ -18,7 +18,6 @@ const {
   outOfBoundsOffsetErr,
   delDuringCompactErr,
   appendLargerThanBlockErr,
-  streamClosedErr,
   appendTransactionWantsArrayErr,
   unexpectedTruncationErr,
 } = require('./errors')
@@ -514,7 +513,7 @@ module.exports = function AsyncAppendOnlyLog(filename, opts) {
   function close(cb) {
     onDrain(function closeAfterHavingDrained() {
       onDeletesFlushed(function closeAfterDeletesFlushed() {
-        for (const stream of self.streams) stream.abort(streamClosedErr())
+        for (const stream of self.streams) stream.abort(true)
         self.streams = []
         raf.close(cb)
       })