chore: regen

Author: infiniteregrets

.speakeasy/gen.lock

@@ -3,10 +3,10 @@ id: 2d20490e-9921-47d5-9711-d3c4b91c8cfa
 management:
   docChecksum: 76d8867e9c1fc8897fc8f35f456e5c46
   docVersion: 1.0.0
-  speakeasyVersion: 1.595.2
-  generationVersion: 2.670.5
-  releaseVersion: 0.15.8
-  configChecksum: 606c5da2e375003210f91dca4bf0e2aa
+  speakeasyVersion: 1.595.3
+  generationVersion: 2.671.2
+  releaseVersion: 0.15.9
+  configChecksum: 0d493ad883ee21ddbe9e1946cb3aa08f
   repoURL: https://github.com/s2-streamstore/s2-sdk-typescript.git
   installationURL: https://github.com/s2-streamstore/s2-sdk-typescript
   published: true
@@ -32,7 +32,7 @@ features:
     responseFormat: 0.2.3
     retries: 2.83.0
     sdkHooks: 0.3.0
-    serverEvents: 0.1.7
+    serverEvents: 0.1.8
     serverEventsSentinels: 0.1.0
     unions: 2.85.11
 generatedFiles:
@@ -325,6 +325,7 @@ generatedFiles:
   - src/types/operations.ts
   - src/types/rfcdate.ts
   - src/types/streams.ts
+  - temp/example.ts
   - tsconfig.json
 examples:
   list_access_tokens:

.speakeasy/gen.yaml

@@ -24,7 +24,7 @@ generation:
     generateNewTests: false
     skipResponseBodyAssertions: false
 typescript:
-  version: 0.15.8
+  version: 0.15.9
   additionalDependencies:
     dependencies:
       uuid: ^9.0.1

.speakeasy/workflow.lock

@@ -1,4 +1,4 @@
-speakeasyVersion: 1.595.2
+speakeasyVersion: 1.595.3
 sources:
     S2 API:
         sourceNamespace: s-2-api
@@ -14,7 +14,7 @@ targets:
         sourceRevisionDigest: sha256:1e3f9a236e5b03e8b366389aecef8db454f5ab6e8e80b790e144e843cefdf85f
         sourceBlobDigest: sha256:a88b5983bb9a8349bc854e15958c127df65ddd0178d52938020049aefd84040d
         codeSamplesNamespace: s-2-api-typescript-code-samples
-        codeSamplesRevisionDigest: sha256:42b3d065745e252275058740b8605abf7e01e5d40b3e2cdce73445f7b5d14473
+        codeSamplesRevisionDigest: sha256:f315e03e69d0a46fd091d1f7bb1e09a03fd7ac8278d9664fee3d74a3e1847549
 workflow:
     workflowVersion: 1.0.0
     speakeasyVersion: latest

examples/package-lock.json

@@ -2,7 +2,7 @@
 
 {
   "name": "@s2-dev/streamstore",
-  "version": "0.15.8",
+  "version": "0.15.9",
   "exports": {
     ".": "./src/index.ts",    
     "./models/errors": "./src/models/errors/index.ts",    

jsr.json

@@ -1,6 +1,6 @@
 {
   "name": "@s2-dev/streamstore",
-  "version": "0.15.8",
+  "version": "0.15.9",
   "author": "Speakeasy",
   "type": "module",
   "bin": {

package-lock.json

@@ -58,8 +58,8 @@ export function serverURLFromOptions(options: SDKOptions): URL | null {
 export const SDK_METADATA = {
   language: "typescript",
   openapiDocVersion: "1.0.0",
-  sdkVersion: "0.15.8",
-  genVersion: "2.670.5",
+  sdkVersion: "0.15.9",
+  genVersion: "2.671.2",
   userAgent:
-    "speakeasy-sdk/typescript 0.15.8 2.670.5 1.0.0 @s2-dev/streamstore",
+    "speakeasy-sdk/typescript 0.15.9 2.671.2 1.0.0 @s2-dev/streamstore",
 } as const;

package.json

@@ -13,34 +13,37 @@ export class EventStream<T extends ServerEvent<unknown>>
   extends ReadableStream<T>
 {
   constructor(
-    stream: ReadableStream<Uint8Array>,
+    responseBody: ReadableStream<Uint8Array>,
     parse: (x: ServerEvent<string>) => IteratorResult<T, undefined>,
   ) {
-    const reader = stream.getReader();
+    const upstream = responseBody.getReader();
     let buffer: Uint8Array = new Uint8Array();
     super({
-      async pull(controller) {
+      async pull(downstream) {
         try {
           while (true) {
-            const r = await reader.read();
-            if (r.done) return controller.close();
-            buffer = concatBuffer(buffer, r.value);
-            for (const { chunk, remainder } of chunks(buffer)) {
-              buffer = remainder;
-              const item = parseChunk(chunk, parse);
-              if (item?.value) controller.enqueue(item.value);
-              if (item?.done) {
-                await reader.cancel("done");
-                return controller.close();
-              }
+            const match = findBoundary(buffer);
+            if (!match) {
+              const chunk = await upstream.read();
+              if (chunk.done) return downstream.close();
+              buffer = concatBuffer(buffer, chunk.value);
+              continue;
+            }
+            const message = buffer.slice(0, match.index);
+            buffer = buffer.slice(match.index + match.length);
+            const item = parseMessage(message, parse);
+            if (item?.value) return downstream.enqueue(item.value);
+            if (item?.done) {
+              await upstream.cancel("done");
+              return downstream.close();
             }
           }
         } catch (e) {
-          await reader.cancel(e);
-          controller.error(e);
+          downstream.error(e);
+          await upstream.cancel(e);
         }
       },
-      cancel: reason => reader.cancel(reason),
+      cancel: reason => upstream.cancel(reason),
     });
   }
 
@@ -105,22 +108,7 @@ function findBoundary(
   return null;
 }
 
-function* chunks(
-  remainder: Uint8Array,
-): Generator<{ chunk: Uint8Array; remainder: Uint8Array }> {
-  while (true) {
-    const match = findBoundary(remainder);
-    if (!match) {
-      yield { chunk: new Uint8Array(), remainder };
-      return;
-    }
-    const chunk = remainder.slice(0, match.index);
-    remainder = remainder.slice(match.index + match.length);
-    yield { chunk, remainder };
-  }
-}
-
-function parseChunk<T extends ServerEvent<unknown>>(
+function parseMessage<T extends ServerEvent<unknown>>(
   chunk: Uint8Array,
   parse: (x: ServerEvent<string>) => IteratorResult<T, undefined>,
 ) {

src/lib/config.ts

@@ -19,7 +19,7 @@ const routes = buildRouteMap({
 export const app = buildApplication(routes, {
   name: "mcp",
   versionInfo: {
-    currentVersion: "0.15.8",
+    currentVersion: "0.15.9",
   },
 });