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 cefa58f commit 716c584Copy full SHA for 716c584
src/cmap/connection.ts
@@ -621,7 +621,7 @@ export class Connection extends TypedEventEmitter<ConnectionEvents> {
621
*/
622
private async *readMany(): AsyncGenerator<OpMsgResponse | OpQueryResponse> {
623
try {
624
- this.dataEvents = this.dataEvents = onData(this.messageStream);
+ this.dataEvents = onData(this.messageStream);
625
for await (const message of this.dataEvents) {
626
const response = await decompressResponse(message);
627
yield response;
0 commit comments