Function Test_Defer_Error

factory_test.go:260–268

(t *testing.T)

}

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

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