Skip to content

Commit 23c3eef

Browse files
fix: avoid gzip buffering during streaming
1 parent 69c050a commit 23c3eef

1 file changed

Lines changed: 16 additions & 4 deletions

File tree

lib/stagehand/resources/sessions.rb

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,11 @@ def act_streaming(id, params)
7777
path: ["v1/sessions/%1$s/act", id],
7878
headers: {
7979
"accept" => "text/event-stream",
80+
"accept-encoding" => "identity",
8081
**parsed.slice(*header_params.keys)
81-
}.transform_keys(header_params),
82+
}.transform_keys(
83+
header_params
84+
),
8285
body: parsed.except(*header_params.keys),
8386
stream: Stagehand::Internal::Stream,
8487
model: Stagehand::StreamEvent,
@@ -193,8 +196,11 @@ def execute_streaming(id, params)
193196
path: ["v1/sessions/%1$s/agentExecute", id],
194197
headers: {
195198
"accept" => "text/event-stream",
199+
"accept-encoding" => "identity",
196200
**parsed.slice(*header_params.keys)
197-
}.transform_keys(header_params),
201+
}.transform_keys(
202+
header_params
203+
),
198204
body: parsed.except(*header_params.keys),
199205
stream: Stagehand::Internal::Stream,
200206
model: Stagehand::StreamEvent,
@@ -279,8 +285,11 @@ def extract_streaming(id, params = {})
279285
path: ["v1/sessions/%1$s/extract", id],
280286
headers: {
281287
"accept" => "text/event-stream",
288+
"accept-encoding" => "identity",
282289
**parsed.slice(*header_params.keys)
283-
}.transform_keys(header_params),
290+
}.transform_keys(
291+
header_params
292+
),
284293
body: parsed.except(*header_params.keys),
285294
stream: Stagehand::Internal::Stream,
286295
model: Stagehand::StreamEvent,
@@ -397,8 +406,11 @@ def observe_streaming(id, params = {})
397406
path: ["v1/sessions/%1$s/observe", id],
398407
headers: {
399408
"accept" => "text/event-stream",
409+
"accept-encoding" => "identity",
400410
**parsed.slice(*header_params.keys)
401-
}.transform_keys(header_params),
411+
}.transform_keys(
412+
header_params
413+
),
402414
body: parsed.except(*header_params.keys),
403415
stream: Stagehand::Internal::Stream,
404416
model: Stagehand::StreamEvent,

0 commit comments

Comments
 (0)