build(deps): bump github.com/tochemey/goakt/v4 from 4.1.0 to 4.1.1 by dependabot[bot] · Pull Request #389 · GoCodeAlone/workflow

dependabot · 2026-03-30T07:49:56Z

Bumps github.com/tochemey/goakt/v4 from 4.1.0 to 4.1.1.

Release notes

Sourced from github.com/tochemey/goakt/v4's releases.

v4.1.1

✨ New Additions

🌊 stream Package — Reactive Streams for GoAkt

A new top-level stream package brings demand-driven, actor-native stream processing to GoAkt. Every pipeline stage runs inside a GoAkt actor, inheriting supervision, lifecycle management, and location transparency automatically. Pipelines are lazy: nothing executes until RunnableGraph.Run is called against a live ActorSystem.

🧩 Core Abstractions

Abstraction Description

Source[T] Lazy description of a stream origin; assembled with Via / To into a RunnableGraph

Flow[In, Out] Lazy description of a transformation stage; type-safe, composable

Sink[T] Lazy description of a terminal consumer stage

RunnableGraph Fully assembled pipeline; a value type that can be Run multiple times for independent instances

StreamHandle Live handle returned by Run; exposes ID(), Done(), Err(), Stop(ctx), Abort(), and Metrics()

📥 Sources

Constructor Description

Of[T](https://github.com/tochemey/goakt/blob/HEAD/values...) 📋 Finite source from a fixed set of values

Range(start, end) 🔢 Integer range source ([start, end))

FromChannel[T](https://github.com/tochemey/goakt/blob/HEAD/ch) 📡 Reads from a Go channel; completes when the channel closes

FromActor[T](https://github.com/tochemey/goakt/blob/HEAD/pid) 🤖 Pulls from a GoAkt actor using the PullRequest / PullResponse[T] protocol

Tick(interval) ⏱️ Emits time.Time on a fixed interval; runs until cancelled

Merge[T](https://github.com/tochemey/goakt/blob/HEAD/sources...) 🔀 Fans N sources into one; completes when all inputs complete

Combine[T,U,V](https://github.com/tochemey/goakt/blob/HEAD/left, right, fn) 🤝 Zips two sources pairwise via fn; zip semantics

Broadcast[T](https://github.com/tochemey/goakt/blob/HEAD/src, n) 📢 Fans one source out to N independent branches

Balance[T](https://github.com/tochemey/goakt/blob/HEAD/src, n) ⚖️ Distributes one source across N branches (round-robin with backpressure)

FromConn(conn, bufSize) 🌐 Reads []byte frames from a net.Conn

Unfold[S,T](https://github.com/tochemey/goakt/blob/HEAD/seed, step) 🌱 Generates values from a seed with a stateful step function

🔄 Flows

Constructor Description

Map[In,Out](https://github.com/tochemey/goakt/blob/HEAD/fn) 🗺️ Type-changing transformation; no error path

TryMap[In,Out](https://github.com/tochemey/goakt/blob/HEAD/fn) 🛡️ Transformation with error; ErrorStrategy controls failure handling

Filter[T](https://github.com/tochemey/goakt/blob/HEAD/predicate) 🔍 Keeps only elements where predicate returns true

FlatMap[In,Out](https://github.com/tochemey/goakt/blob/HEAD/fn) 📤 Expands each element into a slice of outputs

Flatten[T]() 📦 Unwraps []T elements into individual elements

Batch[T](https://github.com/tochemey/goakt/blob/HEAD/n, maxWait) 📦 Groups elements into []T slices of at most n; flushes early after maxWait

Buffer[T](https://github.com/tochemey/goakt/blob/HEAD/size, strategy) 💾 Asynchronous buffer with configurable overflow strategy

Throttle[T](https://github.com/tochemey/goakt/blob/HEAD/n, per) 🚦 Limits throughput to at most n elements per per duration

Deduplicate[T]() 🔁 Suppresses consecutive duplicate elements (T must be comparable)

Scan[In,State](https://github.com/tochemey/goakt/blob/HEAD/zero, fn) 📊 Running accumulation; emits each intermediate state

... (truncated)

Changelog

Sourced from github.com/tochemey/goakt/v4's changelog.

[v4.1.1] - 2026-03-27

✨ New Additions

🌊 stream package — Reactive Streams for GoAkt

A new top-level stream package brings demand-driven, actor-native stream processing to GoAkt. Every pipeline stage runs inside a GoAkt actor, inheriting supervision, lifecycle management, and location transparency automatically. Pipelines are lazy: nothing executes until RunnableGraph.Run is called against a live ActorSystem.

Core abstractions

Source[T] — lazy description of a stream origin; assembled with Via / To into a RunnableGraph.

Flow[In, Out] — lazy description of a transformation stage; type-safe, composable.

Sink[T] — lazy description of a terminal consumer stage.

RunnableGraph — fully assembled pipeline; a value type that can be Run multiple times for independent instances.

StreamHandle — live handle returned by Run; exposes ID(), Done(), Err(), Stop(ctx), Abort(), and Metrics().

Sources

Constructor Description

Of[T](https://github.com/Tochemey/goakt/blob/main/values...) Finite source from a fixed set of values

Range(start, end) Integer range source ([start, end))

FromChannel[T](https://github.com/Tochemey/goakt/blob/main/ch) Reads from a Go channel; completes when the channel closes

FromActor[T](https://github.com/Tochemey/goakt/blob/main/pid) Pulls from a GoAkt actor using the PullRequest / PullResponse[T] protocol

Tick(interval) Emits time.Time on a fixed interval; runs until cancelled

Merge[T](https://github.com/Tochemey/goakt/blob/main/sources...) Fans N sources into one; completes when all inputs complete

Combine[T,U,V](https://github.com/Tochemey/goakt/blob/main/left, right, fn) Zips two sources pairwise via fn; zip semantics

Broadcast[T](https://github.com/Tochemey/goakt/blob/main/src, n) Fans one source out to N independent branches

Balance[T](https://github.com/Tochemey/goakt/blob/main/src, n) Distributes one source across N branches (round-robin with backpressure)

FromConn(conn, bufSize) Reads []byte frames from a net.Conn

Unfold[S,T](https://github.com/Tochemey/goakt/blob/main/seed, step) Generates values from a seed with a stateful step function

Flows

Constructor Description

Map[In,Out](https://github.com/Tochemey/goakt/blob/main/fn) Type-changing transformation; no error path

TryMap[In,Out](https://github.com/Tochemey/goakt/blob/main/fn) Transformation with error; ErrorStrategy controls failure handling

Filter[T](https://github.com/Tochemey/goakt/blob/main/predicate) Keeps only elements where predicate returns true

FlatMap[In,Out](https://github.com/Tochemey/goakt/blob/main/fn) Expands each element into a slice of outputs

Flatten[T]() Unwraps []T elements into individual elements

Batch[T](https://github.com/Tochemey/goakt/blob/main/n, maxWait) Groups elements into []T slices of at most n; flushes early after maxWait

Buffer[T](https://github.com/Tochemey/goakt/blob/main/size, strategy) Asynchronous buffer with configurable overflow strategy

Throttle[T](https://github.com/Tochemey/goakt/blob/main/n, per) Limits throughput to at most n elements per per duration

Deduplicate[T]() Suppresses consecutive duplicate elements (T must be comparable)

Scan[In,State](https://github.com/Tochemey/goakt/blob/main/zero, fn) Running accumulation; emits each intermediate state

WithContext[T](https://github.com/Tochemey/goakt/blob/main/key, value) Labels a tracing boundary; passes elements through unchanged

... (truncated)

Commits

8430aef docs: ✨ update changelog.md to set latest release date and version
29d86c0 chore: upgrade dependencies
b94cc3f chore(deps): update dependency golangci/golangci-lint to v2.11.3 (#1130)
9840287 chore(deps): update module github.com/bufbuild/buf to v1.66.1 (#1129)
f2bda88 chore(deps): update golang docker tag to v1.26.1 (#1128)
88ebbb7 chore(deps): update dependency go to v1.26.1 (#1127)
9bbafa4 chore: upgrade dependencies
c91e09c chore(deps): upgrade dependencies to fix security issue
f6bca2e feat: add streaming capabilities (#1126)
fd0c14f chore(deps): update actions/upload-artifact action to v7 (#1125)
Additional commits viewable in compare view

github-actions · 2026-03-30T08:01:59Z

⏱ Benchmark Results

✅ No significant performance regressions detected.

benchstat comparison (baseline → PR)

## benchstat: baseline → PR
baseline-bench.txt:245: parsing iteration count: invalid syntax
baseline-bench.txt:324084: parsing iteration count: invalid syntax
baseline-bench.txt:659329: parsing iteration count: invalid syntax
baseline-bench.txt:986897: parsing iteration count: invalid syntax
baseline-bench.txt:1287573: parsing iteration count: invalid syntax
baseline-bench.txt:1631683: parsing iteration count: invalid syntax
benchmark-results.txt:245: parsing iteration count: invalid syntax
benchmark-results.txt:354627: parsing iteration count: invalid syntax
benchmark-results.txt:706261: parsing iteration count: invalid syntax
benchmark-results.txt:1053806: parsing iteration count: invalid syntax
benchmark-results.txt:1420902: parsing iteration count: invalid syntax
benchmark-results.txt:1738852: parsing iteration count: invalid syntax
goos: linux
goarch: amd64
pkg: github.com/GoCodeAlone/workflow/dynamic
cpu: AMD EPYC 7763 64-Core Processor                
                            │ baseline-bench.txt │
                            │       sec/op       │
InterpreterCreation-4              3.138m ± 215%
ComponentLoad-4                    3.588m ±  10%
ComponentExecute-4                 1.937µ ±   1%
PoolContention/workers-1-4         1.082µ ±   5%
PoolContention/workers-2-4         1.082µ ±   2%
PoolContention/workers-4-4         1.087µ ±   1%
PoolContention/workers-8-4         1.086µ ±   1%
PoolContention/workers-16-4        1.089µ ±   2%
ComponentLifecycle-4               3.587m ±   1%
SourceValidation-4                 2.237µ ±   1%
RegistryConcurrent-4               817.6n ±   4%
LoaderLoadFromString-4             3.618m ±   1%
geomean                            17.42µ

                            │ baseline-bench.txt │
                            │        B/op        │
InterpreterCreation-4               2.027Mi ± 0%
ComponentLoad-4                     2.180Mi ± 0%
ComponentExecute-4                  1.203Ki ± 0%
PoolContention/workers-1-4          1.203Ki ± 0%
PoolContention/workers-2-4          1.203Ki ± 0%
PoolContention/workers-4-4          1.203Ki ± 0%
PoolContention/workers-8-4          1.203Ki ± 0%
PoolContention/workers-16-4         1.203Ki ± 0%
ComponentLifecycle-4                2.183Mi ± 0%
SourceValidation-4                  1.984Ki ± 0%
RegistryConcurrent-4                1.133Ki ± 0%
LoaderLoadFromString-4              2.182Mi ± 0%
geomean                             15.25Ki

                            │ baseline-bench.txt │
                            │     allocs/op      │
InterpreterCreation-4                15.68k ± 0%
ComponentLoad-4                      18.02k ± 0%
ComponentExecute-4                    25.00 ± 0%
PoolContention/workers-1-4            25.00 ± 0%
PoolContention/workers-2-4            25.00 ± 0%
PoolContention/workers-4-4            25.00 ± 0%
PoolContention/workers-8-4            25.00 ± 0%
PoolContention/workers-16-4           25.00 ± 0%
ComponentLifecycle-4                 18.07k ± 0%
SourceValidation-4                    32.00 ± 0%
RegistryConcurrent-4                  2.000 ± 0%
LoaderLoadFromString-4               18.06k ± 0%
geomean                               183.3

cpu: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz
                            │ benchmark-results.txt │
                            │        sec/op         │
InterpreterCreation-4                 3.332m ± 208%
ComponentLoad-4                       3.515m ±   1%
ComponentExecute-4                    2.053µ ±   1%
PoolContention/workers-1-4            1.221µ ±   3%
PoolContention/workers-2-4            1.216µ ±   1%
PoolContention/workers-4-4            1.217µ ±   1%
PoolContention/workers-8-4            1.222µ ±   1%
PoolContention/workers-16-4           1.235µ ±   1%
ComponentLifecycle-4                  3.611m ±   1%
SourceValidation-4                    2.317µ ±   0%
RegistryConcurrent-4                  890.6n ±   8%
LoaderLoadFromString-4                3.635m ±   2%
geomean                               18.65µ

                            │ benchmark-results.txt │
                            │         B/op          │
InterpreterCreation-4                  2.027Mi ± 0%
ComponentLoad-4                        2.180Mi ± 0%
ComponentExecute-4                     1.203Ki ± 0%
PoolContention/workers-1-4             1.203Ki ± 0%
PoolContention/workers-2-4             1.203Ki ± 0%
PoolContention/workers-4-4             1.203Ki ± 0%
PoolContention/workers-8-4             1.203Ki ± 0%
PoolContention/workers-16-4            1.203Ki ± 0%
ComponentLifecycle-4                   2.183Mi ± 0%
SourceValidation-4                     1.984Ki ± 0%
RegistryConcurrent-4                   1.133Ki ± 0%
LoaderLoadFromString-4                 2.182Mi ± 0%
geomean                                15.25Ki

                            │ benchmark-results.txt │
                            │       allocs/op       │
InterpreterCreation-4                   15.68k ± 0%
ComponentLoad-4                         18.02k ± 0%
ComponentExecute-4                       25.00 ± 0%
PoolContention/workers-1-4               25.00 ± 0%
PoolContention/workers-2-4               25.00 ± 0%
PoolContention/workers-4-4               25.00 ± 0%
PoolContention/workers-8-4               25.00 ± 0%
PoolContention/workers-16-4              25.00 ± 0%
ComponentLifecycle-4                    18.07k ± 0%
SourceValidation-4                       32.00 ± 0%
RegistryConcurrent-4                     2.000 ± 0%
LoaderLoadFromString-4                  18.06k ± 0%
geomean                                  183.3

pkg: github.com/GoCodeAlone/workflow/middleware
cpu: AMD EPYC 7763 64-Core Processor                
                                  │ baseline-bench.txt │
                                  │       sec/op       │
CircuitBreakerDetection-4                  288.3n ± 5%
CircuitBreakerExecution_Success-4          22.52n ± 0%
CircuitBreakerExecution_Failure-4          65.26n ± 3%
geomean                                    75.10n

                                  │ baseline-bench.txt │
                                  │        B/op        │
CircuitBreakerDetection-4                 144.0 ± 0%
CircuitBreakerExecution_Success-4         0.000 ± 0%
CircuitBreakerExecution_Failure-4         0.000 ± 0%
geomean                                              ¹
¹ summaries must be >0 to compute geomean

                                  │ baseline-bench.txt │
                                  │     allocs/op      │
CircuitBreakerDetection-4                 1.000 ± 0%
CircuitBreakerExecution_Success-4         0.000 ± 0%
CircuitBreakerExecution_Failure-4         0.000 ± 0%
geomean                                              ¹
¹ summaries must be >0 to compute geomean

cpu: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz
                                  │ benchmark-results.txt │
                                  │        sec/op         │
CircuitBreakerDetection-4                     455.6n ± 2%
CircuitBreakerExecution_Success-4             59.76n ± 0%
CircuitBreakerExecution_Failure-4             64.84n ± 1%
geomean                                       120.9n

                                  │ benchmark-results.txt │
                                  │         B/op          │
CircuitBreakerDetection-4                    144.0 ± 0%
CircuitBreakerExecution_Success-4            0.000 ± 0%
CircuitBreakerExecution_Failure-4            0.000 ± 0%
geomean                                                 ¹
¹ summaries must be >0 to compute geomean

                                  │ benchmark-results.txt │
                                  │       allocs/op       │
CircuitBreakerDetection-4                    1.000 ± 0%
CircuitBreakerExecution_Success-4            0.000 ± 0%
CircuitBreakerExecution_Failure-4            0.000 ± 0%
geomean                                                 ¹
¹ summaries must be >0 to compute geomean

pkg: github.com/GoCodeAlone/workflow/module
cpu: AMD EPYC 7763 64-Core Processor                
                                 │ baseline-bench.txt │
                                 │       sec/op       │
JQTransform_Simple-4                     869.3n ± 30%
JQTransform_ObjectConstruction-4         1.445µ ±  0%
JQTransform_ArraySelect-4                3.283µ ±  2%
JQTransform_Complex-4                    38.50µ ±  1%
JQTransform_Throughput-4                 1.767µ ±  1%
SSEPublishDelivery-4                     68.97n ±  2%
geomean                                  1.638µ

                                 │ baseline-bench.txt │
                                 │        B/op        │
JQTransform_Simple-4                   1.273Ki ± 0%
JQTransform_ObjectConstruction-4       1.773Ki ± 0%
JQTransform_ArraySelect-4              2.625Ki ± 0%
JQTransform_Complex-4                  16.22Ki ± 0%
JQTransform_Throughput-4               1.984Ki ± 0%
SSEPublishDelivery-4                     0.000 ± 0%
geomean                                             ¹
¹ summaries must be >0 to compute geomean

                                 │ baseline-bench.txt │
                                 │     allocs/op      │
JQTransform_Simple-4                     10.00 ± 0%
JQTransform_ObjectConstruction-4         15.00 ± 0%
JQTransform_ArraySelect-4                30.00 ± 0%
JQTransform_Complex-4                    324.0 ± 0%
JQTransform_Throughput-4                 17.00 ± 0%
SSEPublishDelivery-4                     0.000 ± 0%
geomean                                             ¹
¹ summaries must be >0 to compute geomean

cpu: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz
                                 │ benchmark-results.txt │
                                 │        sec/op         │
JQTransform_Simple-4                        881.5n ± 33%
JQTransform_ObjectConstruction-4            1.487µ ±  2%
JQTransform_ArraySelect-4                   3.209µ ±  1%
JQTransform_Complex-4                       35.61µ ±  1%
JQTransform_Throughput-4                    1.784µ ±  2%
SSEPublishDelivery-4                        76.58n ±  1%
geomean                                     1.654µ

                                 │ benchmark-results.txt │
                                 │         B/op          │
JQTransform_Simple-4                      1.273Ki ± 0%
JQTransform_ObjectConstruction-4          1.773Ki ± 0%
JQTransform_ArraySelect-4                 2.625Ki ± 0%
JQTransform_Complex-4                     16.22Ki ± 0%
JQTransform_Throughput-4                  1.984Ki ± 0%
SSEPublishDelivery-4                        0.000 ± 0%
geomean                                                ¹
¹ summaries must be >0 to compute geomean

                                 │ benchmark-results.txt │
                                 │       allocs/op       │
JQTransform_Simple-4                        10.00 ± 0%
JQTransform_ObjectConstruction-4            15.00 ± 0%
JQTransform_ArraySelect-4                   30.00 ± 0%
JQTransform_Complex-4                       324.0 ± 0%
JQTransform_Throughput-4                    17.00 ± 0%
SSEPublishDelivery-4                        0.000 ± 0%
geomean                                                ¹
¹ summaries must be >0 to compute geomean

pkg: github.com/GoCodeAlone/workflow/schema
cpu: AMD EPYC 7763 64-Core Processor                
                                    │ baseline-bench.txt │
                                    │       sec/op       │
SchemaValidation_Simple-4                    1.095µ ± 9%
SchemaValidation_AllFields-4                 1.689µ ± 7%
SchemaValidation_FormatValidation-4          1.598µ ± 4%
SchemaValidation_ManySchemas-4               1.805µ ± 4%
geomean                                      1.519µ

                                    │ baseline-bench.txt │
                                    │        B/op        │
SchemaValidation_Simple-4                   0.000 ± 0%
SchemaValidation_AllFields-4                0.000 ± 0%
SchemaValidation_FormatValidation-4         0.000 ± 0%
SchemaValidation_ManySchemas-4              0.000 ± 0%
geomean                                                ¹
¹ summaries must be >0 to compute geomean

                                    │ baseline-bench.txt │
                                    │     allocs/op      │
SchemaValidation_Simple-4                   0.000 ± 0%
SchemaValidation_AllFields-4                0.000 ± 0%
SchemaValidation_FormatValidation-4         0.000 ± 0%
SchemaValidation_ManySchemas-4              0.000 ± 0%
geomean                                                ¹
¹ summaries must be >0 to compute geomean

cpu: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz
                                    │ benchmark-results.txt │
                                    │        sec/op         │
SchemaValidation_Simple-4                       1.026µ ± 8%
SchemaValidation_AllFields-4                    1.508µ ± 2%
SchemaValidation_FormatValidation-4             1.495µ ± 1%
SchemaValidation_ManySchemas-4                  1.470µ ± 2%
geomean                                         1.358µ

                                    │ benchmark-results.txt │
                                    │         B/op          │
SchemaValidation_Simple-4                      0.000 ± 0%
SchemaValidation_AllFields-4                   0.000 ± 0%
SchemaValidation_FormatValidation-4            0.000 ± 0%
SchemaValidation_ManySchemas-4                 0.000 ± 0%
geomean                                                   ¹
¹ summaries must be >0 to compute geomean

                                    │ benchmark-results.txt │
                                    │       allocs/op       │
SchemaValidation_Simple-4                      0.000 ± 0%
SchemaValidation_AllFields-4                   0.000 ± 0%
SchemaValidation_FormatValidation-4            0.000 ± 0%
SchemaValidation_ManySchemas-4                 0.000 ± 0%
geomean                                                   ¹
¹ summaries must be >0 to compute geomean

pkg: github.com/GoCodeAlone/workflow/store
cpu: AMD EPYC 7763 64-Core Processor                
                                   │ baseline-bench.txt │
                                   │       sec/op       │
EventStoreAppend_InMemory-4                1.260µ ±  9%
EventStoreAppend_SQLite-4                  1.339m ±  3%
GetTimeline_InMemory/events-10-4           13.92µ ±  2%
GetTimeline_InMemory/events-50-4           78.47µ ±  2%
GetTimeline_InMemory/events-100-4          125.2µ ± 27%
GetTimeline_InMemory/events-500-4          646.8µ ±  0%
GetTimeline_InMemory/events-1000-4         1.324m ±  1%
GetTimeline_SQLite/events-10-4             105.1µ ±  1%
GetTimeline_SQLite/events-50-4             246.2µ ±  1%
GetTimeline_SQLite/events-100-4            418.8µ ±  0%
GetTimeline_SQLite/events-500-4            1.785m ±  0%
GetTimeline_SQLite/events-1000-4           3.491m ±  1%
geomean                                    220.7µ

                                   │ baseline-bench.txt │
                                   │        B/op        │
EventStoreAppend_InMemory-4                 768.5 ± 10%
EventStoreAppend_SQLite-4                 1.985Ki ±  2%
GetTimeline_InMemory/events-10-4          7.953Ki ±  0%
GetTimeline_InMemory/events-50-4          46.62Ki ±  0%
GetTimeline_InMemory/events-100-4         94.48Ki ±  0%
GetTimeline_InMemory/events-500-4         472.8Ki ±  0%
GetTimeline_InMemory/events-1000-4        944.3Ki ±  0%
GetTimeline_SQLite/events-10-4            16.74Ki ±  0%
GetTimeline_SQLite/events-50-4            87.14Ki ±  0%
GetTimeline_SQLite/events-100-4           175.4Ki ±  0%
GetTimeline_SQLite/events-500-4           846.1Ki ±  0%
GetTimeline_SQLite/events-1000-4          1.639Mi ±  0%
geomean                                   67.19Ki

                                   │ baseline-bench.txt │
                                   │     allocs/op      │
EventStoreAppend_InMemory-4                  7.000 ± 0%
EventStoreAppend_SQLite-4                    53.00 ± 0%
GetTimeline_InMemory/events-10-4             125.0 ± 0%
GetTimeline_InMemory/events-50-4             653.0 ± 0%
GetTimeline_InMemory/events-100-4           1.306k ± 0%
GetTimeline_InMemory/events-500-4           6.514k ± 0%
GetTimeline_InMemory/events-1000-4          13.02k ± 0%
GetTimeline_SQLite/events-10-4               382.0 ± 0%
GetTimeline_SQLite/events-50-4              1.852k ± 0%
GetTimeline_SQLite/events-100-4             3.681k ± 0%
GetTimeline_SQLite/events-500-4             18.54k ± 0%
GetTimeline_SQLite/events-1000-4            37.29k ± 0%
geomean                                     1.162k

cpu: Intel(R) Xeon(R) Platinum 8370C CPU @ 2.80GHz
                                   │ benchmark-results.txt │
                                   │        sec/op         │
EventStoreAppend_InMemory-4                   1.127µ ± 20%
EventStoreAppend_SQLite-4                     953.3µ ±  4%
GetTimeline_InMemory/events-10-4              13.56µ ±  2%
GetTimeline_InMemory/events-50-4              75.41µ ±  2%
GetTimeline_InMemory/events-100-4             119.4µ ± 28%
GetTimeline_InMemory/events-500-4             605.8µ ±  1%
GetTimeline_InMemory/events-1000-4            1.224m ±  1%
GetTimeline_SQLite/events-10-4                83.16µ ±  1%
GetTimeline_SQLite/events-50-4                238.5µ ±  1%
GetTimeline_SQLite/events-100-4               420.8µ ±  1%
GetTimeline_SQLite/events-500-4               1.903m ±  1%
GetTimeline_SQLite/events-1000-4              3.749m ±  2%
geomean                                       205.9µ

                                   │ benchmark-results.txt │
                                   │         B/op          │
EventStoreAppend_InMemory-4                     767.0 ± 9%
EventStoreAppend_SQLite-4                     1.983Ki ± 1%
GetTimeline_InMemory/events-10-4              7.953Ki ± 0%
GetTimeline_InMemory/events-50-4              46.62Ki ± 0%
GetTimeline_InMemory/events-100-4             94.48Ki ± 0%
GetTimeline_InMemory/events-500-4             472.8Ki ± 0%
GetTimeline_InMemory/events-1000-4            944.3Ki ± 0%
GetTimeline_SQLite/events-10-4                16.74Ki ± 0%
GetTimeline_SQLite/events-50-4                87.14Ki ± 0%
GetTimeline_SQLite/events-100-4               175.4Ki ± 0%
GetTimeline_SQLite/events-500-4               846.1Ki ± 0%
GetTimeline_SQLite/events-1000-4              1.639Mi ± 0%
geomean                                       67.18Ki

                                   │ benchmark-results.txt │
                                   │       allocs/op       │
EventStoreAppend_InMemory-4                     7.000 ± 0%
EventStoreAppend_SQLite-4                       53.00 ± 0%
GetTimeline_InMemory/events-10-4                125.0 ± 0%
GetTimeline_InMemory/events-50-4                653.0 ± 0%
GetTimeline_InMemory/events-100-4              1.306k ± 0%
GetTimeline_InMemory/events-500-4              6.514k ± 0%
GetTimeline_InMemory/events-1000-4             13.02k ± 0%
GetTimeline_SQLite/events-10-4                  382.0 ± 0%
GetTimeline_SQLite/events-50-4                 1.852k ± 0%
GetTimeline_SQLite/events-100-4                3.681k ± 0%
GetTimeline_SQLite/events-500-4                18.54k ± 0%
GetTimeline_SQLite/events-1000-4               37.29k ± 0%
geomean                                        1.162k

Benchmarks run with go test -bench=. -benchmem -count=6.
Regressions ≥ 20% are flagged. Results compared via benchstat.

intel352 · 2026-03-30T16:58:36Z

@dependabot recreate

Bumps [github.com/tochemey/goakt/v4](https://github.com/tochemey/goakt) from 4.1.0 to 4.1.1. - [Release notes](https://github.com/tochemey/goakt/releases) - [Changelog](https://github.com/Tochemey/goakt/blob/main/CHANGELOG.md) - [Commits](Tochemey/goakt@v4.1.0...v4.1.1) --- updated-dependencies: - dependency-name: github.com/tochemey/goakt/v4 dependency-version: 4.1.1 dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com>

dependabot bot added dependencies Pull requests that update a dependency file go Pull requests that update go code labels Mar 30, 2026

dependabot bot force-pushed the dependabot/go_modules/github.com/tochemey/goakt/v4-4.1.1 branch from 9d132cb to 8375928 Compare March 30, 2026 17:00

intel352 merged commit 9317545 into main Apr 5, 2026
15 of 16 checks passed

intel352 deleted the dependabot/go_modules/github.com/tochemey/goakt/v4-4.1.1 branch April 5, 2026 04:11

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

build(deps): bump github.com/tochemey/goakt/v4 from 4.1.0 to 4.1.1#389

build(deps): bump github.com/tochemey/goakt/v4 from 4.1.0 to 4.1.1#389
intel352 merged 1 commit intomainfrom
dependabot/go_modules/github.com/tochemey/goakt/v4-4.1.1

dependabot bot commented on behalf of github Mar 30, 2026 •

edited

Loading

Uh oh!

github-actions bot commented Mar 30, 2026 •

edited

Loading

Uh oh!

intel352 commented Mar 30, 2026

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

1 participant

Abstraction	Description
`Source[T]`	Lazy description of a stream origin; assembled with `Via` / `To` into a `RunnableGraph`
`Flow[In, Out]`	Lazy description of a transformation stage; type-safe, composable
`Sink[T]`	Lazy description of a terminal consumer stage
`RunnableGraph`	Fully assembled pipeline; a value type that can be `Run` multiple times for independent instances
`StreamHandle`	Live handle returned by `Run`; exposes `ID()`, `Done()`, `Err()`, `Stop(ctx)`, `Abort()`, and `Metrics()`

Constructor	Description
`Of[T](https://github.com/tochemey/goakt/blob/HEAD/values...)`	📋 Finite source from a fixed set of values
`Range(start, end)`	🔢 Integer range source (`[start, end)`)
`FromChannel[T](https://github.com/tochemey/goakt/blob/HEAD/ch)`	📡 Reads from a Go channel; completes when the channel closes
`FromActor[T](https://github.com/tochemey/goakt/blob/HEAD/pid)`	🤖 Pulls from a GoAkt actor using the `PullRequest` / `PullResponse[T]` protocol
`Tick(interval)`	⏱️ Emits `time.Time` on a fixed interval; runs until cancelled
`Merge[T](https://github.com/tochemey/goakt/blob/HEAD/sources...)`	🔀 Fans N sources into one; completes when all inputs complete
`Combine[T,U,V](https://github.com/tochemey/goakt/blob/HEAD/left, right, fn)`	🤝 Zips two sources pairwise via `fn`; zip semantics
`Broadcast[T](https://github.com/tochemey/goakt/blob/HEAD/src, n)`	📢 Fans one source out to N independent branches
`Balance[T](https://github.com/tochemey/goakt/blob/HEAD/src, n)`	⚖️ Distributes one source across N branches (round-robin with backpressure)
`FromConn(conn, bufSize)`	🌐 Reads `[]byte` frames from a `net.Conn`
`Unfold[S,T](https://github.com/tochemey/goakt/blob/HEAD/seed, step)`	🌱 Generates values from a seed with a stateful step function

Constructor	Description
`Map[In,Out](https://github.com/tochemey/goakt/blob/HEAD/fn)`	🗺️ Type-changing transformation; no error path
`TryMap[In,Out](https://github.com/tochemey/goakt/blob/HEAD/fn)`	🛡️ Transformation with error; ErrorStrategy controls failure handling
`Filter[T](https://github.com/tochemey/goakt/blob/HEAD/predicate)`	🔍 Keeps only elements where `predicate` returns true
`FlatMap[In,Out](https://github.com/tochemey/goakt/blob/HEAD/fn)`	📤 Expands each element into a slice of outputs
`Flatten[T]()`	📦 Unwraps `[]T` elements into individual elements
`Batch[T](https://github.com/tochemey/goakt/blob/HEAD/n, maxWait)`	📦 Groups elements into `[]T` slices of at most `n`; flushes early after `maxWait`
`Buffer[T](https://github.com/tochemey/goakt/blob/HEAD/size, strategy)`	💾 Asynchronous buffer with configurable overflow strategy
`Throttle[T](https://github.com/tochemey/goakt/blob/HEAD/n, per)`	🚦 Limits throughput to at most `n` elements per `per` duration
`Deduplicate[T]()`	🔁 Suppresses consecutive duplicate elements (`T` must be comparable)
`Scan[In,State](https://github.com/tochemey/goakt/blob/HEAD/zero, fn)`	📊 Running accumulation; emits each intermediate state

Constructor	Description
`Of[T](https://github.com/Tochemey/goakt/blob/main/values...)`	Finite source from a fixed set of values
`Range(start, end)`	Integer range source (`[start, end)`)
`FromChannel[T](https://github.com/Tochemey/goakt/blob/main/ch)`	Reads from a Go channel; completes when the channel closes
`FromActor[T](https://github.com/Tochemey/goakt/blob/main/pid)`	Pulls from a GoAkt actor using the `PullRequest` / `PullResponse[T]` protocol
`Tick(interval)`	Emits `time.Time` on a fixed interval; runs until cancelled
`Merge[T](https://github.com/Tochemey/goakt/blob/main/sources...)`	Fans N sources into one; completes when all inputs complete
`Combine[T,U,V](https://github.com/Tochemey/goakt/blob/main/left, right, fn)`	Zips two sources pairwise via `fn`; zip semantics
`Broadcast[T](https://github.com/Tochemey/goakt/blob/main/src, n)`	Fans one source out to N independent branches
`Balance[T](https://github.com/Tochemey/goakt/blob/main/src, n)`	Distributes one source across N branches (round-robin with backpressure)
`FromConn(conn, bufSize)`	Reads `[]byte` frames from a `net.Conn`
`Unfold[S,T](https://github.com/Tochemey/goakt/blob/main/seed, step)`	Generates values from a seed with a stateful step function

Constructor	Description
`Map[In,Out](https://github.com/Tochemey/goakt/blob/main/fn)`	Type-changing transformation; no error path
`TryMap[In,Out](https://github.com/Tochemey/goakt/blob/main/fn)`	Transformation with error; ErrorStrategy controls failure handling
`Filter[T](https://github.com/Tochemey/goakt/blob/main/predicate)`	Keeps only elements where `predicate` returns true
`FlatMap[In,Out](https://github.com/Tochemey/goakt/blob/main/fn)`	Expands each element into a slice of outputs
`Flatten[T]()`	Unwraps `[]T` elements into individual elements
`Batch[T](https://github.com/Tochemey/goakt/blob/main/n, maxWait)`	Groups elements into `[]T` slices of at most `n`; flushes early after `maxWait`
`Buffer[T](https://github.com/Tochemey/goakt/blob/main/size, strategy)`	Asynchronous buffer with configurable overflow strategy
`Throttle[T](https://github.com/Tochemey/goakt/blob/main/n, per)`	Limits throughput to at most `n` elements per `per` duration
`Deduplicate[T]()`	Suppresses consecutive duplicate elements (`T` must be comparable)
`Scan[In,State](https://github.com/Tochemey/goakt/blob/main/zero, fn)`	Running accumulation; emits each intermediate state
`WithContext[T](https://github.com/Tochemey/goakt/blob/main/key, value)`	Labels a tracing boundary; passes elements through unchanged

Conversation

dependabot bot commented on behalf of github Mar 30, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

v4.1.1

✨ New Additions

🌊 stream Package — Reactive Streams for GoAkt

🧩 Core Abstractions

📥 Sources

🔄 Flows

[v4.1.1] - 2026-03-27

✨ New Additions

🌊 stream package — Reactive Streams for GoAkt

Uh oh!

github-actions bot commented Mar 30, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

⏱ Benchmark Results

Uh oh!

intel352 commented Mar 30, 2026

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

1 participant

dependabot bot commented on behalf of github Mar 30, 2026 •

edited

Loading

🌊 `stream` Package — Reactive Streams for GoAkt

🌊 `stream` package — Reactive Streams for GoAkt

github-actions bot commented Mar 30, 2026 •

edited

Loading