README
¶
event
异步事件分发类，可组合后使用。
参数 handles 为不定长，事件触发时按照链式顺序逐一调用，可使用 e.Abort() 中断。
脱胎于原项目 event.go
使用
package event_test
import (
"errors"
"strconv"
"testing"
"time"
"github.com/Drelf2018/event"
)
func TestAsyncEvent(t *testing.T) {
evt := event.AsyncEventS[int]{}
evt.OnEqual("1", func(e *event.Event, v int) {
t.Logf("OnEqual: %v\n", v)
e.Abort()
}, func(*event.Event, int) {
panic(errors.New("this error will not panic"))
})
evt.OnRegexp(`\d+`, func(e *event.Event, v int) {
t.Logf("OnRegexp: %v\n", v)
})
ch := evt.Channel(strconv.Itoa)
defer close(ch)
event.Heartbeat(0, 1000, func(b *event.Beat) {
t.Logf("Heartbeat#%v\n", b.Count)
ch <- b.Count
if b.Count == 2 {
time.Sleep(500 * time.Millisecond)
b.Abort()
}
})
}
控制台
=== RUN TestAsyncEvent
async_test.go:30: Heartbeat#1
async_test.go:16: OnEqual: 1
async_test.go:23: OnRegexp: 1
async_test.go:30: Heartbeat#2
async_test.go:23: OnRegexp: 2
--- PASS: TestAsyncEvent (1.50s)
PASS
ok github.com/Drelf2018/event 1.532s
Documentation
¶
Index ¶
- Constants
- func Dispatch[K comparable, V any](chains []Chain[V], cmd K, data V)
- func Heartbeat(initdead, keepalive float64, f func(*Beat))
- type AsyncEvent
- func (a *AsyncEvent[K, V]) Channel(key func(V) K) chan<- V
- func (a *AsyncEvent[K, V]) Del(name string, cmd K, index int) error
- func (a *AsyncEvent[K, V]) Dispatch(cmd K, data V)
- func (a *AsyncEvent[K, V]) On(name string, cmd K, handles ...Handle[V]) (int, error)
- func (a *AsyncEvent[K, V]) OnEqual(cmd K, handles ...Handle[V]) (int, error)
- func (a *AsyncEvent[K, V]) Register(name string, rule Rule[K, V]) *AsyncEvent[K, V]
- func (a *AsyncEvent[K, V]) Rule(name string) (r Rule[K, V], err error)
- type AsyncEventS
- type Beat
- type Chain
- type Equal
- type Event
- type Handle
- type Regexp
- type Rule
Constants ¶
View Source
const ( EQUAL string = "equal" REGEXP string = "regexp" )
Variables ¶
This section is empty.
Functions ¶
func Dispatch ¶ added in v0.4.0
func Dispatch[K comparable, V any](chains []Chain[V], cmd K, data V)
Types ¶
type AsyncEvent ¶
type AsyncEvent[K comparable, V any] struct { // contains filtered or unexported fields }
func New ¶
func New[K comparable, V any]() AsyncEvent[K, V]
func (*AsyncEvent[K, V]) Channel ¶ added in v0.4.0
func (a *AsyncEvent[K, V]) Channel(key func(V) K) chan<- V
func (*AsyncEvent[K, V]) Del ¶ added in v0.4.0
func (a *AsyncEvent[K, V]) Del(name string, cmd K, index int) error
func (*AsyncEvent[K, V]) Dispatch ¶
func (a *AsyncEvent[K, V]) Dispatch(cmd K, data V)
func (*AsyncEvent[K, V]) On ¶
func (a *AsyncEvent[K, V]) On(name string, cmd K, handles ...Handle[V]) (int, error)
func (*AsyncEvent[K, V]) OnEqual ¶ added in v0.3.0
func (a *AsyncEvent[K, V]) OnEqual(cmd K, handles ...Handle[V]) (int, error)
func (*AsyncEvent[K, V]) Register ¶
func (a *AsyncEvent[K, V]) Register(name string, rule Rule[K, V]) *AsyncEvent[K, V]
type AsyncEventS ¶
type AsyncEventS[V any] struct { AsyncEvent[string, V] // contains filtered or unexported fields }
func Default ¶
func Default[V any]() AsyncEventS[V]
type Equal ¶ added in v0.3.0
type Equal[K comparable, V any] map[K][]Chain[V]
Source Files
Click to show internal directories.
Click to hide internal directories.