Version Packages (#100)

github-actions[bot] · himself65 · web-flow · commit 4201aabb0de8 · 2025-05-02T08:29:03.000-07:00
Co-authored-by: github-actions[bot] &lt;41898282+github-actions[bot]@users.noreply.github.com&gt;
Co-authored-by: himself65 &lt;14026360+himself65@users.noreply.github.com&gt;
diff --git a/.changeset/wicked-ladybugs-stare.md b/.changeset/wicked-ladybugs-stare.md
diff --git a/docs/package.json b/docs/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@llama-flow/docs",
-  "version": "0.0.7",
+  "version": "0.0.8",
   "files": [
     "llamaflow"
   ],
diff --git a/packages/core/CHANGELOG.md b/packages/core/CHANGELOG.md
@@ -1,5 +1,45 @@
 # @llama-flow/core
 
+## 0.4.1
+
+### Patch Changes
+
+- 1005e84: feat: add stream helper
+
+  In this release, we built-in some stream helper (inspired from (TC39 Async Iterator Helpers)[https://github.com/tc39/proposal-async-iterator-helpers])
+
+  - move `@llama-flow/core/stream/until` into `stream.until`
+  - move `@llama-flow/core/stream/filter` into `stream.filter`
+  - move `@llama-flow/core/stream/consumer` into `stream.toArray()`
+  - add `stream.take(limit)`
+  - add `stream.toArray()`
+
+  ```diff
+  - import { collect } from "@llama-flow/core/stream/consumer";
+  - import { until } from "@llama-flow/core/stream/until";
+  - import { filter } from "@llama-flow/core/stream/filter";
+
+  -  const results = await collect(
+  -    until(
+  -      filter(
+  -        stream,
+  -        (ev) =>
+  -          processedValidEvent.include(ev) || processedInvalidEvent.include(ev),
+  -      ),
+  -      () => {
+  -        return results.length >= totalItems;
+  -      },
+  -    ),
+  -  );
+  +  const results = await stream
+  +    .filter(
+  +      (ev) =>
+  +        processedValidEvent.include(ev) || processedInvalidEvent.include(ev),
+  +    )
+  +    .take(totalItems)
+  +    .toArray();
+  ```
+
 ## 0.4.0
 
 ### Minor Changes
diff --git a/packages/core/jsr.json b/packages/core/jsr.json
@@ -1,6 +1,6 @@
 {
   "name": "@llama-flow/core",
-  "version": "0.4.0",
+  "version": "0.4.1",
   "exports": {
     ".": "./src/core/index.ts",
     "./async-context": "./src/async-context/index.ts",
diff --git a/packages/core/package.json b/packages/core/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@llama-flow/core",
-  "version": "0.4.0",
+  "version": "0.4.1",
   "description": "event-based workflow engine",
   "type": "module",
   "main": "dist/index.cjs",
diff --git a/packages/llamaindex/CHANGELOG.md b/packages/llamaindex/CHANGELOG.md
@@ -1,5 +1,12 @@
 # @llama-flow/llamaindex
 
+## 0.0.15
+
+### Patch Changes
+
+- Updated dependencies [1005e84]
+  - @llama-flow/core@0.4.1
+
 ## 0.0.14
 
 ### Patch Changes
diff --git a/packages/llamaindex/package.json b/packages/llamaindex/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@llama-flow/llamaindex",
-  "version": "0.0.14",
+  "version": "0.0.15",
   "type": "module",
   "description": "LlamaIndex binding for llama-flow",
   "main": "dist/index.cjs",

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@llama-flow/docs",`
`3`		`- "version": "0.0.7",`
	`3`	`+ "version": "0.0.8",`
`4`	`4`	`"files": [`
`5`	`5`	`"llamaflow"`
`6`	`6`	`],`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@llama-flow/core",`
`3`		`- "version": "0.4.0",`
	`3`	`+ "version": "0.4.1",`
`4`	`4`	`"exports": {`
`5`	`5`	`".": "./src/core/index.ts",`
`6`	`6`	`"./async-context": "./src/async-context/index.ts",`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@llama-flow/llamaindex",`
`3`		`- "version": "0.0.14",`
	`3`	`+ "version": "0.0.15",`
`4`	`4`	`"type": "module",`
`5`	`5`	`"description": "LlamaIndex binding for llama-flow",`
`6`	`6`	`"main": "dist/index.cjs",`