Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for MessageHubBackedServer (0.39 sec)

  2. github.com/gradle/gradle

    platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedServer.java 

    import org.gradle.internal.remote.ObjectConnection;
import org.gradle.internal.remote.internal.ConnectCompletion;

public class MessageHubBackedServer implements MessagingServer {
    private final IncomingConnector connector;
    private final ExecutorFactory executorFactory;

    public MessageHubBackedServer(IncomingConnector connector, ExecutorFactory executorFactory) {
        this.connector = connector;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:59:22 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  3. github.com/gradle/gradle

    platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubBackedServerTest.groovy 

    import spock.lang.Specification

class MessageHubBackedServerTest extends Specification {
    final IncomingConnector connector = Mock()
    final ExecutorFactory executorFactory = Mock()
    final MessageHubBackedServer server = new MessageHubBackedServer(connector, executorFactory)

    def "creates connection and cleans up on stop"() {
        ConnectionAcceptor acceptor = Mock()
        Action<ObjectConnection> connectAction = Mock()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:59:22 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  4. github.com/gradle/gradle

    platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/services/MessagingServices.java 

    import org.gradle.internal.remote.internal.OutgoingConnector;
import org.gradle.internal.remote.internal.hub.MessageHubBackedClient;
import org.gradle.internal.remote.internal.hub.MessageHubBackedServer;
import org.gradle.internal.remote.internal.inet.InetAddressFactory;
import org.gradle.internal.remote.internal.inet.TcpIncomingConnector;
import org.gradle.internal.remote.internal.inet.TcpOutgoingConnector;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. github.com/gradle/gradle

    testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt 

    Class <org.gradle.internal.remote.internal.hub.MessageHubBackedServer$ConnectEventAction> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (MessageHubBackedServer.java:0)
Class <org.gradle.internal.remote.internal.hub.MessageHubBackedServer> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (MessageHubBackedServer.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)
Back to top