asReader - Code Search

subprojects/core/src/main/java/org/gradle/api/internal/resources/FileCollectionBackedTextResource.java

            throw ResourceExceptions.readMissing(file, e);
        } catch (IOException e) {
            throw ResourceExceptions.readFailed(file, e);
        }
    }

    @Override
    public Reader asReader() {
        File file = asFile();
        try {
            return Files.newReader(asFile(), charset);
        } catch (FileNotFoundException e) {
            throw ResourceExceptions.readMissing(file, e);
        }

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Tue Feb 02 16:14:10 UTC 2021

- 3.6K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/jvm/plugins-application/src/main/java/org/gradle/api/internal/plugins/DefaultTemplateBasedStartScriptGenerator.java

    public TextResource getTemplate() {
        return template;
    }

    private String generateStartScriptContentFromTemplate(final Map<String, String> binding) {
        try (Reader reader = getTemplate().asReader()) {
            SimpleTemplateEngine engine = new SimpleTemplateEngine();
            Template template = engine.createTemplate(reader);
            String output = template.make(binding).toString();

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Apr 11 20:20:16 UTC 2024

- 3.7K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/main/java/org/gradle/api/internal/resources/ApiTextResourceAdapter.java

        this.tempFileProvider = tempFileProvider;
    }

    @Override
    public String asString() {
        return getWrappedTextResource().getText();
    }

    @Override
    public Reader asReader() {
        return getWrappedTextResource().getAsReader();
    }

    @Override
    public File asFile(String targetCharset) {
        try {
            File file = getWrappedTextResource().getFile();

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Tue Feb 02 16:14:10 UTC 2021

- 5K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core-api/src/main/java/org/gradle/api/resources/TextResource.java

     *
     * @return a reader that allows the resource's text to be read.
     */
    Reader asReader();

    /**
     * Returns a file containing the resource's text and using the given character encoding.
     * If this resource is backed by a file with a matching encoding, that file may be

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Wed Oct 10 09:43:44 UTC 2018

- 3.1K bytes

- Viewed (0)

github.com/golang/go

src/net/http/httptest/recorder_test.go

				io.WriteString(w, "<html>")
			},
			check(hasHeader("Content-Type", "text/html; charset=utf-8")),
		},
		{
			"no Content-Type detection with Transfer-Encoding",
			func(w http.ResponseWriter, r *http.Request) {
				w.Header().Set("Transfer-Encoding", "some encoding")
				io.WriteString(w, "<html>")
			},
			check(hasHeader("Content-Type", "")), // no header
		},
		{

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Mon Apr 11 23:17:38 UTC 2022

- 9.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

cmd/kube-scheduler/app/server.go

	configz.InstallHandler(pathRecorderMux)
	pathRecorderMux.Handle("/metrics", legacyregistry.HandlerWithReset())

	resourceMetricsHandler := resources.Handler(informers.Core().V1().Pods().Lister())
	pathRecorderMux.HandleFunc("/metrics/resources", func(w http.ResponseWriter, req *http.Request) {
		if !isLeader() {
			return
		}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Mon May 27 19:11:24 UTC 2024

- 14.3K bytes

- Viewed (0)

github.com/golang/go

src/cmd/compile/internal/ssagen/pgen.go

		fmt.Fprintf(os.Stderr, "=-= sorted DCL for %v:\n", fn)
		for i, v := range fn.Dcl {
			if !ssa.IsMergeCandidate(v) {
				continue
			}
			fmt.Fprintf(os.Stderr, " %d: %q isleader=%v subsumed=%v used=%v sz=%d align=%d t=%s\n", i, v.Sym().Name, mls.IsLeader(v), mls.Subsumed(v), v.Used(), v.Type().Size(), v.Type().Alignment(), v.Type().String())
		}
	}

	// Reassign stack offsets of the locals that are used.
	lastHasPtr := false

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Wed May 15 15:44:14 UTC 2024

- 13.1K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/diagnostics/src/test/groovy/org/gradle/api/tasks/diagnostics/internal/insight/DependencyInsightReporterSpec.groovy

        when:
        def sorted = reporter.convertToRenderableItems(dependencies, false)

        then:
        sorted.size() == 2
        verify(sorted[0]) {
            selected 'group:a:1.0'
            isHeader()
            noMoreChildren()
        }
        verify(sorted[1]) {
            selected 'group:a:1.0'
            isNotHeader()
            hasChild('group:b:1.0') {
                noMoreChildren()

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Wed Nov 22 04:22:29 UTC 2023

- 10.3K bytes

- Viewed (0)

github.com/istio/istio

pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go

func (le *LeaderElector) GetLeader() string {
	return le.getObservedRecord().HolderIdentity
}

// IsLeader returns true if the last observed leader was this client else returns false.
func (le *LeaderElector) IsLeader() bool {
	return le.getObservedRecord().HolderIdentity == le.config.Lock.Identity()
}

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Mon Jul 24 04:04:42 UTC 2023

- 16.3K bytes

- Viewed (0)

github.com/istio/istio

pilot/pkg/leaderelection/leaderelection_test.go

	})

	// Need to retry until Run() starts to execute in the goroutine.
	retry.UntilOrFail(t, gotLeader.Load, retry.Converge(5), retry.Delay(time.Millisecond*100), retry.Timeout(time.Second*10))
	if !l.isLeader() {
		t.Errorf("isLeader()=false, want true")
	}

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Sun Apr 28 04:22:19 UTC 2024

- 11.4K bytes

- Viewed (0)

Search Options