Function Test_Defer

factory_test.go:175–183

(t *testing.T)

}

func Test_Defer(t *testing.T) {
	defer goleak.VerifyNone(t)
	obs := Defer([]Producer{func(ctx context.Context, next chan<- Item) {
		next <- Of(1)
		next <- Of(2)
		next <- Of(3)
	}})
	Assert(context.Background(), t, obs, HasItems(1, 2, 3), HasNoError())
}

func Test_Defer_Multiple(t *testing.T) {
	defer goleak.VerifyNone(t)