Skip to content

Commit

Permalink
refactor: minor edit
Browse files Browse the repository at this point in the history
Following 655dce9
  • Loading branch information
darrachequesne committed Feb 3, 2023
1 parent b1eed5f commit 5ba0d49
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions lib/socket.ts
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ interface Flags {
compress?: boolean;
volatile?: boolean;
timeout?: number;
withRetry?: boolean;
fromQueue?: boolean;
}

export type DisconnectDescription =
Expand Down Expand Up @@ -381,7 +381,7 @@ export class Socket<

args.unshift(ev);

if (this._opts.retries && !this.flags.withRetry && !this.flags.volatile) {
if (this._opts.retries && !this.flags.fromQueue && !this.flags.volatile) {
let ack;
if (typeof args[args.length - 1] === "function") {
ack = args.pop();
Expand All @@ -392,7 +392,7 @@ export class Socket<
pending: false,
args,
ack,
flags: Object.assign({ withRetry: true }, this.flags),
flags: Object.assign({ fromQueue: true }, this.flags),
});
this._drainQueue();
return this;
Expand Down

0 comments on commit 5ba0d49

Please sign in to comment.