Skip to content

Commit bc0a9b5

Browse files
authored
fix(WaitForProcessing): change entry condition
1 parent d8cd0e7 commit bc0a9b5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/subscriber.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1000,7 +1000,7 @@ export class Subscriber extends EventEmitter {
10001000
const shutdownStart = Date.now();
10011001
if (
10021002
behavior === SubscriberCloseBehaviors.WaitForProcessing &&
1003-
!this._inventory.isEmpty
1003+
!this._inventory.isEmpty()
10041004
) {
10051005
const waitTimeout = timeout.subtract(FINAL_NACK_TIMEOUT);
10061006

0 commit comments

Comments
 (0)