README
¶
Overview
A lightweight observable lib. Go channel doesn't support unlimited buffer size, it's a pain to decide what size to use, this lib will handle it dynamically.
- unlimited buffer size
- one publisher to multiple subscribers
- thread-safe
- subscribers never block each other
- stable event order
Examples
See examples_test.go.
Benchmark
goos: darwin
goarch: amd64
pkg: github.com/ysmood/goob
cpu: Intel(R) Core(TM) i7-8750H CPU @ 2.20GHz
BenchmarkPublish-12 7493547 143.9 ns/op 86 B/op 0 allocs/op
BenchmarkConsume-12 4258910 275.5 ns/op 0 B/op 0 allocs/op
Documentation
¶
Overview ¶
Example (Basic) ¶
package main
import (
"context"
"fmt"
"time"
"github.com/ysmood/goob"
)
func main() {
ctx, cancel := context.WithTimeout(context.Background(), 200*time.Millisecond)
defer cancel()
// create an observable instance
ob := goob.New(ctx)
events := ob.Subscribe(context.TODO())
// publish events without blocking
ob.Publish(1)
ob.Publish(2)
ob.Publish(3)
// consume events
for e := range events {
fmt.Print(e)
}
}
Output: 123
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Observable ¶
type Observable struct {
// contains filtered or unexported fields
}
Observable hub
Click to show internal directories.
Click to hide internal directories.