- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for addConnection (0.36 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/internal/hub/MessageHubIntegrationTest.groovy
hub.addHandler(channel, handler) } def connectTo(Participant other) { def connector = new TestConnector() hub.addConnection(connector.connectionA) other.hub.addConnection(connector.connectionB) } def stop() { hub.stop() } } private class TestConnector {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHub.java
* Use {@link #addHandler(String, Object)} to create a worker for incoming messages on a given channel. * Use {@link #addConnection(RemoteConnection)} to attach another router to this router. * * TODO - this type could be simplified, as there is no longer any need to send/receive messages to/from multiple connections */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 16.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
new MethodInvocationSerializer( methodParamClassLoader, argsSerializer))); connection = completion.create(serializer); hub.addConnection(connection); hub.noFurtherConnections(); completion = null; } @Override public void requestStop() { hub.requestStop(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0)