File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -206,7 +206,7 @@ export class Connection extends TypedEventEmitter<ConnectionEvents> {
206206 private lastUseTime : number ;
207207 private clusterTime : Document | null = null ;
208208 private error : Error | null = null ;
209- private dataEvents : AsyncGenerator < Uint8Array , void , void > | null = null ;
209+ private dataEvents : AsyncGenerator < Buffer , void , void > | null = null ;
210210
211211 private readonly socketTimeoutMS : number ;
212212 private readonly monitorCommands : boolean ;
@@ -796,7 +796,7 @@ export class SizedMessageTransform extends Transform {
796796 this . connection = connection ;
797797 }
798798
799- override _transform ( chunk : Uint8Array , encoding : unknown , callback : TransformCallback ) : void {
799+ override _transform ( chunk : Buffer , encoding : unknown , callback : TransformCallback ) : void {
800800 if ( this . connection . delayedTimeoutId != null ) {
801801 clearTimeout ( this . connection . delayedTimeoutId ) ;
802802 this . connection . delayedTimeoutId = null ;
You can’t perform that action at this time.
0 commit comments