- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for WithReader (0.21 sec)
-
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/junit/result/BinaryResultBackedTestResultsProvider.java
} @Override public boolean hasOutput(final long classId, final TestOutputEvent.Destination destination) { final boolean[] hasOutput = new boolean[1]; withReader(new Action<TestOutputStore.Reader>() { @Override public void execute(TestOutputStore.Reader reader) { hasOutput[0] = reader.hasOutput(classId, destination); } });
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 3.1K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/junit/result/InMemoryTestResultsProvider.java
this.results = results; } @Override public boolean hasOutput(final long classId, final TestOutputEvent.Destination destination) { final boolean[] hasOutput = new boolean[1]; withReader(new Action<TestOutputStore.Reader>() { @Override public void execute(TestOutputStore.Reader reader) { hasOutput[0] = reader.hasOutput(classId, destination); } });
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 3.4K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/junit/result/TestOutputStoreBackedResultsProvider.java
public TestOutputStoreBackedResultsProvider(TestOutputStore outputStore) { this.outputStore = outputStore; this.readers = new ConcurrentHashMap<Thread, TestOutputStore.Reader>(); } protected void withReader(Action<TestOutputStore.Reader> action) { action.execute(getReader()); } private TestOutputStore.Reader getReader() { Thread thread = Thread.currentThread();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/monitoring/monitoring.go
otelprom.WithRegisterer(reg), otelprom.WithoutCounterSuffixes(), } prom, err := otelprom.New(promOpts...) if err != nil { return nil, err } opts := []metric.Option{metric.WithReader(prom)} opts = append(opts, knownMetrics.toHistogramViews()...) mp := metric.NewMeterProvider(opts...) otel.SetMeterProvider(mp) handler := promhttp.HandlerFor(gatherer, promhttp.HandlerOpts{}) return handler, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 9.5K bytes - Viewed (0)