File tree Expand file tree Collapse file tree 2 files changed +3
-1
lines changed
src/packages/conat/persist Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -108,6 +108,7 @@ class PersistStreamClient extends EventEmitter {
108
108
new ConatError ( headers ?. error , { code : headers ?. code } ) ,
109
109
) ;
110
110
this . close ( ) ;
111
+ return ;
111
112
}
112
113
if ( this . gettingMissed ) {
113
114
this . changesWhenGettingMissed . push ( updates ) ;
Original file line number Diff line number Diff line change @@ -266,6 +266,7 @@ export class PersistentStream extends EventEmitter {
266
266
267
267
private initArchive = ( ) => {
268
268
if ( ! this . options . archive ) {
269
+ this . throttledBackup = ( ) => { } ;
269
270
return ;
270
271
}
271
272
this . throttledBackup = throttle (
@@ -337,7 +338,7 @@ export class PersistentStream extends EventEmitter {
337
338
// reuseInFlight since probably doing a backup on top
338
339
// of itself would corrupt data.
339
340
if ( ! this . options . archive ) {
340
- throw Error ( "no backup target file set" ) ;
341
+ return ;
341
342
}
342
343
const path = this . options . archive + ".db" ;
343
344
try {
You can’t perform that action at this time.
0 commit comments