Skip to content

Commit bb8df95

Browse files
committed
use server provided options for the s2 writer
1 parent 6bd09f6 commit bb8df95

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

packages/core/src/v3/realtimeStreams/manager.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,8 @@ export class StandardRealtimeStreamsManager implements RealtimeStreamsManager {
8181
signal: combinedSignal,
8282
limiter: (await import("p-limit")).default,
8383
debug: this.debug,
84+
flushIntervalMs: parsedResponse.flushIntervalMs,
85+
maxRetries: parsedResponse.maxRetries,
8486
});
8587

8688
this.activeStreams.set(key, { wait: () => streamInstance.wait(), abortController });

0 commit comments

Comments
 (0)