We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 085ca84 commit 6154f98Copy full SHA for 6154f98
src/member-api.js
@@ -472,6 +472,7 @@ export class MemberApi extends TypedEmitter {
472
)
473
}
474
475
+ const onClosePromise = pEvent(websocket, 'close')
476
const onErrorPromise = pEvent(websocket, 'error')
477
478
const replicationStream = this.#getReplicationStream()
@@ -494,7 +495,6 @@ export class MemberApi extends TypedEmitter {
494
495
websocket.close()
496
throw errorEvent.error
497
} else {
- const onClosePromise = pEvent(websocket, 'close')
498
onErrorPromise.cancel()
499
500
await onClosePromise
0 commit comments