- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for AggregatingProblemConsumer (0.39 sec)
-
platforms/ide/tooling-api-builders/src/main/java/org/gradle/tooling/internal/provider/runner/AggregatingProblemConsumer.java
@NonNullApi public class AggregatingProblemConsumer { private final Multimap<String, InternalProblemEventVersion2> seenProblems = ArrayListMultimap.create(); private final ProgressEventConsumer progressEventConsumer; private final Supplier<OperationIdentifier> operationIdentifierSupplier; private int thresholdForIntermediateSummary = 10_000;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 09:50:19 UTC 2024 - 7K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/test/groovy/org/gradle/tooling/internal/provider/runner/AggregatingProblemConsumerTest.groovy
class AggregatingProblemConsumerTest extends Specification { def "distinct events are not aggregated"() { given: def eventConsumer = Mock(ProgressEventConsumer) def emitter = new AggregatingProblemConsumer(eventConsumer, { new OperationIdentifier(1) }) when: for (int i = 0; i < 3; i++) { emitter.emit(createMockProblem("foo$i")) } then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 09:50:19 UTC 2024 - 4.2K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/main/java/org/gradle/tooling/internal/provider/runner/ToolingApiBuildEventListenerFactory.java
Supplier<OperationIdentifier> operationIdentifierSupplier = () -> new OperationIdentifier(idFactory.nextId()); AggregatingProblemConsumer aggregator = new AggregatingProblemConsumer(progressEventConsumer, operationIdentifierSupplier); this.problemAggregator = Optional.of(aggregator);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 13:57:30 UTC 2024 - 7.5K bytes - Viewed (0)