Skip to content

Commit f7208ed

Browse files
committed
fixup: revert unintended change
Signed-off-by: Mirza Brunjadze <[email protected]>
1 parent 5eca890 commit f7208ed

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/clients/consumer/messages-stream.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -571,7 +571,9 @@ export class MessagesStream<Key, Value, HeaderKey, HeaderValue> extends Readable
571571
}
572572

573573
if (canPush && !(this.#shouldClose || this.closed || this.destroyed)) {
574-
this.#fetch()
574+
process.nextTick(() => {
575+
this.#fetch()
576+
})
575577
}
576578
}
577579

0 commit comments

Comments
 (0)