ReactiveX/RxGo

Health v2 · maintenance only

Adoption not part of the score

5098 stars · 342 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-29, confidence not recorded

RxGo is the official ReactiveX implementation for Go, providing composable observable streams built on Go channels and goroutines. It offers a rich set of operators (Map, Filter, etc.) for asynchronous, pipeline-based event processing.

Use cases

• process streams of events asynchronously in Go
• compose data transformation pipelines with map and filter operators
• replace callback-based async code with observable streams
• parallelize operator stages across goroutines
• build reactive data flows over Go channels

When to choose

• you want ReactiveX-style observable programming idioms in Go
• you need composable, parallel stream processing using native channels and goroutines
• you prefer declarative operator chains over manual pipeline plumbing

When to avoid

• your project needs simple sequential code without async complexity
• you need a mature, heavily maintained reactive library with large community support
• Go's standard concurrency primitives already suffice for your use case

Facets

library · maturity active

concurrency streaming serialization developer-tools go cross-platform reactive-extensions observables reactive-programming pipelines asynchronous goroutines algorithms real-time

Member repositories

For agents

markdown · JSON · MCP: product_card(name="ReactiveX/RxGo")