- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for GetProxy (0.18 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/actor/internal/DefaultActorFactorySpec.groovy
} def nonBlockingActorAndProxyAreBothMarkedAsThreadSafe() { when: def actor = factory.createActor(target) then: actor instanceof ThreadSafe actor.getProxy(Runnable) instanceof ThreadSafe } def createsABlockingActorForATargetObject() { when: def actor = factory.createBlockingActor(target) then: actor != null }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 8.1K bytes - Viewed (0) -
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/processors/MaxNParallelTestClassProcessorTest.groovy
1 * actorFactory.createActor(processor1) >> actor1 1 * actor1.getProxy(TestClassProcessor) >> asyncProcessor1 when: processor.processTestClass(test) then: 1 * factory.create() >> processor2 1 * actorFactory.createActor(processor2) >> actor2 1 * actor2.getProxy(TestClassProcessor) >> asyncProcessor2 when: processor.stopNow()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 6.4K bytes - Viewed (0) -
platforms/software/resources-s3/src/test/groovy/org/gradle/internal/resource/transport/aws/s3/S3ConnectionPropertiesTest.groovy
HttpProxySettings secureHttpProxySettings = Mock() 1 * secureHttpProxySettings.getProxy() >> secureProxy when: S3ConnectionProperties properties = new S3ConnectionProperties(Mock(HttpProxySettings), secureHttpProxySettings, null, null) then: properties.getProxy().get() == secureProxy } def "should get non-secure http proxy for override host"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 3.7K bytes - Viewed (0) -
platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/junit/JUnitTestClassProcessor.java
@Override protected Action<String> createTestExecutor(Actor resultProcessorActor) { TestResultProcessor threadSafeResultProcessor = resultProcessorActor.getProxy(TestResultProcessor.class); TestClassExecutionListener threadSafeTestClassListener = resultProcessorActor.getProxy(TestClassExecutionListener.class); JUnitTestEventAdapter junitEventAdapter = new JUnitTestEventAdapter(threadSafeResultProcessor, clock, idGenerator);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/processors/MaxNParallelTestClassProcessor.java
// Create a processor that processes events in its own thread resultProcessorActor = actorFactory.createActor(resultProcessor); this.resultProcessor = resultProcessorActor.getProxy(TestResultProcessor.class); } @Override public void processTestClass(TestClassRunInfo testClass) { if (stoppedNow) { return; } TestClassProcessor processor;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 3.6K bytes - Viewed (0) -
platforms/software/resources-s3/src/main/java/org/gradle/internal/resource/transport/aws/s3/S3ConnectionProperties.java
return endpoint; } public Optional<HttpProxySettings.HttpProxy> getProxy() { if (endpoint.isPresent()) { if (endpoint.get().getScheme().equalsIgnoreCase("HTTP")) { return Optional.fromNullable(proxySettings.getProxy()); } else { return Optional.fromNullable(secureProxySettings.getProxy()); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 4.6K bytes - Viewed (0) -
platforms/software/resources-http/src/test/groovy/org/gradle/internal/resource/transport/http/JavaSystemPropertiesProxySettingsTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 2.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/aether/LegacyRepositorySystemSessionExtender.java
repository.setProxy(getProxy(selector, repository)); } } } private org.apache.maven.repository.Proxy getProxy(ProxySelector selector, ArtifactRepository repository) { if (selector != null) { RemoteRepository repo = RepositoryUtils.toRepo(repository); org.eclipse.aether.repository.Proxy proxy = selector.getProxy(repo); if (proxy != null) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 6.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/Actor.java
/** * <p>An {@code Actor} dispatches method calls to a target object in a thread-safe manner. Methods are called either by * calling {@link Dispatch#dispatch(Object)} on the actor, or using the proxy object * returned by {@link #getProxy(Class)}. Methods are delivered to the target object in the order they are called on the * actor, but are delivered to the target object by a single thread at a time. In this way, the target object does not need
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/testFixtures/groovy/org/gradle/internal/actor/TestActorFactory.java
throw new UnsupportedOperationException(); } @Override public Actor createBlockingActor(final Object target) { return new Actor() { @Override public <T> T getProxy(Class<T> type) { return new ProxyDispatchAdapter<T>(new ReflectionDispatch(target), type, ThreadSafe.class).getSource(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.6K bytes - Viewed (0)