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