739
740
constructor(
741
>
private readonly _tracer: ISocketTracer,
ipc.net.ts
742
>
recordInflateBytes: boolean,
743
>
inflateBytes: VSBuffer | null,
744
>
options: ZlibOptions
745
>
) {
746
>
super();
747
>
this._recordInflateBytes = recordInflateBytes;
748
>
this._zlibInflate = createInflateRaw(options);
749
>
this._zlibInflate.on('error', (err: Error) => {
750
this._tracer.traceSocketEvent(SocketDiagnosticsEventType.zlibInflateError, { message: err?.message, code: (err as NodeJS.ErrnoException)?.code });
751
this._onError.fire(err);
753
>
this._zlibInflate.on('data', (data: Buffer) => {
754
this._tracer.traceSocketEvent(SocketDiagnosticsEventType.zlibInflateData, data);
755
this._pendingInflateData.push(VSBuffer.wrap(data));
757
>
if (inflateBytes) {
758
this._tracer.traceSocketEvent(SocketDiagnosticsEventType.zlibInflateInitialWrite, inflateBytes.buffer);
759
this._zlibInflate.write(inflateBytes.buffer);