Popularity
0.5
Declining
Activity
0.0
Stable
4
2
0
Description
A simplified version of RxJs for golang. (Easier than RxGo)
Programming language: Go
License: GNU Affero General Public License v3.0
Reactive alternatives and similar packages
Based on the "Utilities" category.
Alternatively, view Reactive alternatives based on common mentions on social networks and blogs.
-
项目文档
🚀Vite+Vue3+Gin的开发基础平台,支持TS和JS混用。它集成了JWT鉴权、权限管理、动态路由、显隐可控组件、分页封装、多点登录拦截、资源权限、上传下载、代码生成器、表单生成器和可配置的导入导出等开发必备功能。 -
excelize
Go language library for reading and writing Microsoft Excel™ (XLAM / XLSM / XLSX / XLTM / XLTX) spreadsheets -
Kopia
Cross-platform backup tool for Windows, macOS & Linux with fast, incremental backups, client-side end-to-end encryption, compression and data deduplication. CLI and GUI included. -
goreporter
A Golang tool that does static analysis, unit testing, code review and generate code quality report. -
create-go-app
✨ A complete and self-contained solution for developers of any qualification to create a production-ready project with backend (Go), frontend (JavaScript, TypeScript) and deploy automation (Ansible, Docker) by running only one CLI command. -
EaseProbe
A simple, standalone, and lightweight tool that can do health/status checking, written in Go. -
filetype
Fast, dependency-free Go package to infer binary file types based on the magic numbers header signature -
boilr
:zap: boilerplate template manager that generates files or directories from template repositories -
beaver
💨 A real time messaging system to build a scalable in-app notifications, multiplayer games, chat apps in web and mobile apps. -
go-underscore
Helpfully Functional Go - A useful collection of Go utilities. Designed for programmer happiness.
WorkOS - The modern identity platform for B2B SaaS
The APIs are flexible and easy-to-use, supporting authentication, user identity, and complex enterprise features like SSO and SCIM provisioning.
Promo
workos.com
Do you think we are missing an alternative of Reactive or a related project?
Popular Comparisons
README
Reactive
My attempt on creating a simple RxJs clone
Features
- Observables
- Multi-Type support
- Subjects
- Subject
- ReplaySubject
- Pipes
- Take
- TakeEvery
- Skip
- SkipEvery
Examples
Simple Subject
package main
import (
"github.com/infinytum/reactive"
"fmt"
)
func main() {
subject := reactive.NewSubject()
subject.Subscribe(subHandler)
subject.Next(1)
subject.Next(2)
subject.Next(3)
subject.Next(4)
}
func subHandler(a int) {
fmt.Println(a)
}
Output
$ go run main.go
1
2
3
4
Replay Subject
package main
import (
"github.com/infinytum/reactive"
"fmt"
)
func main() {
subject := reactive.NewReplaySubject()
subject.Next(1)
subject.Next(2)
subject.Next(3)
subject.Subscribe(subHandler)
subject.Next(4)
}
func subHandler(a int) {
fmt.Println(a)
}
Output
$ go run main.go
3
4
Multi-Type support
package main
import (
"github.com/infinytum/reactive"
"fmt"
)
func main() {
subject := reactive.NewSubject()
subject.Subscribe(intHandler)
subject.Subscribe(stringHandler)
subject.Next(2)
subject.Next("Hello")
subject.Next("World")
subject.Next(4)
subject.Next(nil)
}
func intHandler(a int) {
fmt.Print("Int Handler: ")
fmt.Println(a)
}
func stringHandler(a string) {
fmt.Print("String Handler: ")
fmt.Println(a)
}
Output
Int Handler: 2
String Handler: Hello
String Handler: World
Int Handler: 4
Int Handler: 0
String Handler:
Take Pipe
package main
import (
"github.com/infinytum/reactive"
"fmt"
)
func main() {
subject := reactive.NewReplaySubject()
subject.Pipe(reactive.Take(2)).Subscribe(subHandler)
subject.Next(1)
subject.Next(2)
subject.Next(3)
subject.Next(4)
}
func subHandler(a int) {
fmt.Println(a)
}
Output
$ go run main.go
1
2
TakeEvery Pipe
package main
import (
"github.com/infinytum/reactive"
"fmt"
)
func main() {
subject := reactive.NewReplaySubject()
subject.Pipe(reactive.TakeEvery(2)).Subscribe(subHandler)
subject.Next(1)
subject.Next(2)
subject.Next(3)
subject.Next(4)
}
func subHandler(a int) {
fmt.Println(a)
}
Output
$ go run main.go
2
4
Skip Pipe
package main
import (
"github.com/infinytum/reactive"
"fmt"
)
func main() {
subject := reactive.NewReplaySubject()
subject.Pipe(reactive.Skip(2)).Subscribe(subHandler)
subject.Next(1)
subject.Next(2)
subject.Next(3)
subject.Next(4)
}
func subHandler(a int) {
fmt.Println(a)
}
Output
$ go run main.go
3
4
SkipEvery Pipe
package main
import (
"github.com/infinytum/reactive"
"fmt"
)
func main() {
subject := reactive.NewReplaySubject()
subject.Pipe(reactive.SkipEvery(2)).Subscribe(subHandler)
subject.Next(1)
subject.Next(2)
subject.Next(3)
subject.Next(4)
}
func subHandler(a int) {
fmt.Println(a)
}
Output
$ go run main.go
1
3