Nicer API and update the s2 writer to use the new append session

Author: ericallam

packages/core/package.json

@@ -181,7 +181,7 @@
     "@opentelemetry/sdk-trace-base": "2.0.1",
     "@opentelemetry/sdk-trace-node": "2.0.1",
     "@opentelemetry/semantic-conventions": "1.36.0",
-    "@s2-dev/streamstore": "^0.15.13",
+    "@s2-dev/streamstore": "0.17.1",
     "dequal": "^2.0.3",
     "eventsource": "^3.0.5",
     "eventsource-parser": "^3.0.0",

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

@@ -54,7 +54,6 @@ export class StreamInstance<T> implements StreamsWriter {
             accessToken: parsedResponse.accessToken,
             source: this.options.source,
             signal: this.options.signal,
-            limiter: (await import("p-limit")).default,
             debug: this.options.debug,
             flushIntervalMs: parsedResponse.flushIntervalMs,
             maxRetries: parsedResponse.maxRetries,