fix: Remove unneeded heartbeat handling. (#210)

goloroden · web-flow · commit cf2cda1143e0 · 2025-05-15T13:58:55.000+02:00
diff --git a/src/Client.ts b/src/Client.ts
@@ -161,9 +161,6 @@ class Client {
 				}
 
 				for await (const line of readNdJsonStream(response.body, combinedSignal)) {
-					if (isStreamHeartbeat(line)) {
-						continue;
-					}
 					if (isStreamError(line)) {
 						throw new Error(`${line.payload.error}.`);
 					}
@@ -229,9 +226,6 @@ class Client {
 				}
 
 				for await (const line of readNdJsonStream(response.body, combinedSignal)) {
-					if (isStreamHeartbeat(line)) {
-						continue;
-					}
 					if (isStreamError(line)) {
 						throw new Error(`${line.payload.error}.`);
 					}

Original file line number	Diff line number	Diff line change
`@@ -161,9 +161,6 @@ class Client {`
`161`	`161`	`}`
`162`	`162`
`163`	`163`	`for await (const line of readNdJsonStream(response.body, combinedSignal)) {`
`164`		`- if (isStreamHeartbeat(line)) {`
`165`		`- continue;`
`166`		`- }`
`167`	`164`	`if (isStreamError(line)) {`
`168`	`165`	throw new Error(`${line.payload.error}.`);
`169`	`166`	`}`
`@@ -229,9 +226,6 @@ class Client {`
`229`	`226`	`}`
`230`	`227`
`231`	`228`	`for await (const line of readNdJsonStream(response.body, combinedSignal)) {`
`232`		`- if (isStreamHeartbeat(line)) {`
`233`		`- continue;`
`234`		`- }`
`235`	`229`	`if (isStreamError(line)) {`
`236`	`230`	throw new Error(`${line.payload.error}.`);
`237`	`231`	`}`