// reporting on a watch stream since this package may not import a higher level report.
type Reporter interface {
	// AsObject must convert err into a valid runtime.Object for the watch stream.
	AsObject(err error) runtime.Object
}

// StreamWatcher turns any stream for which you can write a Decoder interface
// into a watch.Interface.
type StreamWatcher struct {
	sync.Mutex

	}
	return item.Type, item.Object, nil
}

func (f fakeDecoder) Close() {
	if f.items != nil {
		close(f.items)
	}
}

type fakeReporter struct {
	err error
}

func (f *fakeReporter) AsObject(err error) runtime.Object {
	f.err = err
	return runtime.Unstructured(nil)
}

func TestStreamWatcher(t *testing.T) {
	table := []Event{
		{Type: Added, Object: testType("foo")},
	}

	return &ErrorReporter{
		code:   code,
		verb:   verb,
		reason: reason,
	}
}

// AsObject returns a valid error runtime.Object (a v1.Status) for the given
// error, using the code and verb of the reporter type. The error is set to
// indicate that this was an unexpected server response.
func (r *ErrorReporter) AsObject(err error) runtime.Object {

        val subject = ConfigurationCacheProblemsSummary(maxCollectedProblems = 2)
        assertTrue(
            "1st problem",
            subject.onProblem(buildLogicProblem("build.gradle", "failure"), ProblemSeverity.Failure)
        )
        assertTrue(
            "2nd problem (same message as 1st but different location)",

        keep = orig.createFile('keep')

        subject = testDirectory.createDir('test/subject')
        remove = subject.createFile("remove")
        link = subject.file('link')
        createSymbolicLink(link, orig)

        assert orig.isDirectory()
        assert orig.exists()
        assert subject.isDirectory()
        assert subject.exists()
        assert keep.exists()
        assert remove.exists()

func ValidateRoleBindingSubject(subject rbac.Subject, isNamespaced bool, fldPath *field.Path) field.ErrorList {
	allErrs := field.ErrorList{}

	if len(subject.Name) == 0 {
		allErrs = append(allErrs, field.Required(fldPath.Child("name"), ""))
	}

	switch subject.Kind {
	case rbac.ServiceAccountKind:
		if len(subject.Name) > 0 {

import spock.lang.Specification
import spock.lang.Subject

@Subject(MutationGuards)
class MutationGuardsTest extends Specification {
    def "can get mutation guard of guard aware instance"() {
        given:
        def subject = Mock(WithMutationGuard)

        when:
        MutationGuards.of(subject)

        then:
        1 * subject.getMutationGuard()
        0 * subject._
    }

        given:
        def subject = new OrdinalGroupFactory()

        when:
        def g2 = subject.group(2)
        def g0 = subject.group(0)
        def g1 = subject.group(1)

        then:
        subject.allGroups == [g0, g1, g2]
    }

    def 'returns the same group for the same ordinal'() {
        given:
        def subject = new OrdinalGroupFactory()

        when:

        )
    }

    def "creates unbound rules for multiple binders"() {
        binder {
            descriptor("firstRule")
            subjectReference("path.subject.first", String)
        }
        binder {
            descriptor("secondRule")
            subjectReference("path.subject.second", Number)
        }

        expect:

        @Mutate
        void theRule(List subject, String input1, Integer input2, Set input3) {
            subject.add(input1)
            subject.add(input2)
            subject.addAll(input3)
        }
    }

    static class ArrayListRuleSource {
        @Mutate
        void theRule(ArrayList subject, String input1, Integer input2, Set input3) {
            subject.add(input1)
            subject.add(input2)