- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for MessageHubBackedObjectConnection (0.44 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
import org.slf4j.LoggerFactory; import java.util.ArrayList; import java.util.HashSet; import java.util.List; import java.util.Set; public class MessageHubBackedObjectConnection implements ObjectConnection { private static final Logger LOGGER = LoggerFactory.getLogger(MessageHubBackedObjectConnection.class); private final MessageHub hub; private final List<Action<Throwable>> unrecoverableErrorHandlers = new ArrayList<Action<Throwable>>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedClient.java
this.connector = connector; this.executorFactory = executorFactory; } @Override public ObjectConnection getConnection(Address address) { return new MessageHubBackedObjectConnection(executorFactory, connector.connect(address)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedServer.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnectionTest.groovy
import org.gradle.test.fixtures.concurrent.ConcurrentSpec class MessageHubBackedObjectConnectionTest extends ConcurrentSpec { def connectCompletion = Mock(ConnectCompletion) def connectionBuilder = new MessageHubBackedObjectConnection(executorFactory, connectCompletion) interface Worker { void doStuff(String value) } interface CompletableWorker extends Worker, StreamCompletion { }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt
Class <org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$1> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (MessageHubBackedObjectConnection.java:0) Class <org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$2> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (MessageHubBackedObjectConnection.java:0)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 967.9K bytes - Viewed (0)