v0.13.0

Features

• feat(flow): implement rolling fold transformation by @Wkkkkk in #162
• feat(flow): add support for allowed lateness in sliding window by @reugn in #177

Fixes

• fix(flow)!: sliding window blocks until the first window is elapsed by @reugn in #165
• fix(flow): use of sliding window in keyed flow by @reugn in #176

Improvements

• refactor(flow): use atomic.Int64 in Throttler by @reugn in #169
• refactor(flow): rework parallel processing of stream elements by @reugn in #178

Connectors

• deps(connectors): update dependency versions by @reugn in #183

Maintenance

• chore: update code documentation and rework the maze example by @reugn in #167
• docs(flow): enhance keyed flow documentation by @reugn in #181
• ci: upgrade golangci-lint to v2.1.5 by @reugn in #182

New Contributors

• @Wkkkkk made their first contribution in #162

Full Changelog: v0.12.0...v0.13.0