Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for WithReader (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top