Function TestPublish

chainbus/bus_test.go:91–99

(t *testing.T)

}

func TestPublish(t *testing.T) {
	bus := New()
	bus.Subscribe("/event/test", func(a int, b int) {
		if a != b {
			t.Fail()
		}
	})
	bus.Publish("/event/test", 10, 10)
}

func TestSubcribeOnceAsync(t *testing.T) {
	results := make([]int, 0)