go-streams
go-streams copied to clipboard
A lightweight stream processing library for Go
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.21.0 to 0.23.0. Commits c48da13 http2: fix TestServerContinuationFlood flakes 762b58d http2: fix tipos in comment ba87210 http2: close connections when receiving too many headers ebc8168 all: fix...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.21.0 to 0.23.0. Commits c48da13 http2: fix TestServerContinuationFlood flakes 762b58d http2: fix tipos in comment ba87210 http2: close connections when receiving too many headers ebc8168 all: fix...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.17.0 to 0.23.0. Commits c48da13 http2: fix TestServerContinuationFlood flakes 762b58d http2: fix tipos in comment ba87210 http2: close connections when receiving too many headers ebc8168 all: fix...
After I read the example coud files in this repo. I cannot find a right way to achieve stream's `group` function or `keyBy` function. such as 'partition(stream, key=lambda x: x['country'])'...
Bumps google.golang.org/protobuf from 1.31.0 to 1.33.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Bumps google.golang.org/protobuf from 1.31.0 to 1.33.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Bumps google.golang.org/protobuf from 1.30.0 to 1.33.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Bumps [github.com/nats-io/nats-server/v2](https://github.com/nats-io/nats-server) from 2.1.9 to 2.9.23. Release notes Sourced from github.com/nats-io/nats-server/v2's releases. Release v2.9.23 Changelog Go Version 1.20.10 Fixed Accounts Prevent bypassing authorization block when enabling system account access in...
Bumps [github.com/nats-io/jwt](https://github.com/nats-io/jwt) from 1.2.2 to 2.4.0+incompatible. Release notes Sourced from github.com/nats-io/jwt's releases. v2.4.0 What's Changed [FEAT] added support for external authorization for accounts. by @derekcollison in nats-io/jwt#179, nats-io/jwt#180, nats-io/jwt#185, nats-io/jwt#186,...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.21.0 to 0.23.0. Commits c48da13 http2: fix TestServerContinuationFlood flakes 762b58d http2: fix tipos in comment ba87210 http2: close connections when receiving too many headers ebc8168 all: fix...