Function TestPubSub

pkg/events/basic/pubsub_test.go:37–47

(t *testing.T)

var timeout = (1 << 10) * test.Delay

func TestPubSub(t *testing.T) { //nolint:paralleltest
	events.IncludeCaller = true

	test.RunTest(t, test.TestConfig{
		Timeout: timeout,
		Func: func(ctx context.Context, a *assertions.Assertion) {
			pubsub := basic.NewPubSub()
			eventstest.TestBackend(ctx, t, a, pubsub)
		},
	})
}