Function TestSubscribeAsync

chainbus/bus_test.go:147–173

(t *testing.T)

}

func TestSubscribeAsync(t *testing.T) {
	results := make(chan int)

	bus := New()
	bus.SubscribeAsync("/event/test", func(a int, out chan<- int) {
		out <- a
	}, false)

	bus.Publish("/event/test", 1, results)
	bus.Publish("/event/test", 2, results)

	var numResults int32

	go func() {
		for range results {
			atomic.AddInt32(&numResults, 1)
		}
	}()

	bus.WaitAsync()

	time.Sleep(10 * time.Millisecond)

	if atomic.LoadInt32(&numResults) != 2 {
		t.Fail()
	}
}