From 9f661b710a970fd0da61fc08dac2812a7896b6d6 Mon Sep 17 00:00:00 2001
From: Pavel Feldman <pavel.feldman@gmail.com>
Date: Mon, 17 Apr 2023 21:36:08 -0400
Subject: [PATCH] chore: bump the trace packet size to be 1Mb (#22446)

---
 packages/playwright-core/src/client/stream.ts                 | 4 ++--
 .../src/server/dispatchers/artifactDispatcher.ts              | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/packages/playwright-core/src/client/stream.ts b/packages/playwright-core/src/client/stream.ts
index 483f0e82c7..bb202ac4ad 100644
--- a/packages/playwright-core/src/client/stream.ts
+++ b/packages/playwright-core/src/client/stream.ts
@@ -40,8 +40,8 @@ class StreamImpl extends Readable {
     this._channel = channel;
   }
 
-  override async _read(size: number) {
-    const result = await this._channel.read({ size });
+  override async _read() {
+    const result = await this._channel.read({ size: 1024 * 1024 });
     if (result.binary.byteLength)
       this.push(result.binary);
     else
diff --git a/packages/playwright-core/src/server/dispatchers/artifactDispatcher.ts b/packages/playwright-core/src/server/dispatchers/artifactDispatcher.ts
index 6d954f75f6..d898e19e61 100644
--- a/packages/playwright-core/src/server/dispatchers/artifactDispatcher.ts
+++ b/packages/playwright-core/src/server/dispatchers/artifactDispatcher.ts
@@ -73,7 +73,7 @@ export class ArtifactDispatcher extends Dispatcher<Artifact, channels.ArtifactCh
           return;
         }
         try {
-          const readable = fs.createReadStream(localPath);
+          const readable = fs.createReadStream(localPath, { highWaterMark: 1024 * 1024 });
           const stream = new StreamDispatcher(this, readable);
           // Resolve with a stream, so that client starts saving the data.
           resolve({ stream });
@@ -94,7 +94,7 @@ export class ArtifactDispatcher extends Dispatcher<Artifact, channels.ArtifactCh
     const fileName = await this._object.localPathAfterFinished();
     if (!fileName)
       return {};
-    const readable = fs.createReadStream(fileName);
+    const readable = fs.createReadStream(fileName, { highWaterMark: 1024 * 1024 });
     return { stream: new StreamDispatcher(this, readable) };
   }