Streaming semantics (API)

[embano1]

I just learned about this project (been using RxGo), and the API and helpers look really useful.

I mostly work on streaming-based systems/APIs in Go so was wondering if you're also considering adding support for such use cases?

E.g. filter and map based on a stream (Go channel?) of Order structs coming from a messaging system (Kafka, Rabbit, Redis) or HTTP (gRPC) poll/push API.

[fsouza]

Disclaimer: I'm not a maintainer

@embano1 I imagine RxGo will eventually adopt generics?

[embano1]

@embano1 I imagine RxGo will eventually adopt generics?

Yes, this is my understanding, but not sure if the project currently has the bandwidth

[serge-hulne]

Here is an alternative to RxGo (with generics) : https://github.com/serge-hulne/go_iter