event

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