Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 1,340 for connector (0.13 sec)

  1. platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/DefaultProjectConnection.java

        private final AsyncConsumerActionExecutor connection;
        private final ConnectionParameters parameters;
        private final ProjectConnectionCloseListener listener;
    
        public DefaultProjectConnection(AsyncConsumerActionExecutor connection, ConnectionParameters parameters, ProjectConnectionCloseListener listener) {
            this.connection = connection;
            this.parameters = parameters;
            this.listener = listener;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 12:11:05 UTC 2024
    - 5K bytes
    - Viewed (0)
  2. platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/UnicastMessagingIntegrationTest.groovy

            given:
            client.addIncoming(service)
            server.setupOutgoingService1()
            server.setupOutgoingService2()
    
            and:
            client.connection.connect()
            server.connection.connect()
    
    
            when:
            server.outgoingService1.doStuff("1")
            server.outgoingService1.doStuff("2")
            server.outgoingService1.doStuff("3")
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 09:21:43 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r83/TestFailureProgressEventCrossVersionTest.groovy

                    }
                }
            '''
            def collector = new TestFailureEventCollector()
    
            when:
            runTestTaskWithFailureCollection(collector)
    
            then:
            thrown(BuildException)
            collector.failures.size() == 1
            collector.failures[0] instanceof DefaultTestAssertionFailure
    
            DefaultTestAssertionFailure failure = collector.failures[0] as DefaultTestAssertionFailure
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 6.7K bytes
    - Viewed (0)
  4. platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/DefaultBuildActionExecuter.java

        private final AsyncConsumerActionExecutor connection;
    
        public DefaultBuildActionExecuter(BuildAction<T> buildAction, AsyncConsumerActionExecutor connection, ConnectionParameters parameters) {
            super(parameters);
            operationParamsBuilder.setEntryPoint("BuildActionExecuter API");
            this.buildAction = buildAction;
            this.connection = connection;
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 12:11:05 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/ReportStatusDispatcherTest.groovy

            connection.dispatch(message) >> { throw new RuntimeException("Cannot dispatch") }
    
            when:
            dispatcher.dispatch(connection, message)
    
            then:
            0 * connection.receive()
            noExceptionThrown()
        }
    
        def "ignores failed receive"() {
            given:
            def message = new ReportStatus(UUID.randomUUID(), "TOKEN".bytes)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/StopDispatcherTest.groovy

            connection.dispatch(message) >> { throw new RuntimeException("Cannot dispatch") }
    
            when:
            dispatcher.dispatch(connection, message)
    
            then:
            0 * connection.receive()
            noExceptionThrown()
        }
    
        def "ignores failed receive"() {
            given:
            def message = new Stop(UUID.randomUUID())
            connection.receive() >> { throw new RuntimeException("Cannot dispatch") }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  7. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r112/PublicationsCrossVersionSpec.groovy

            ProjectPublications publications = withConnection { connection ->
                connection.getModel(ProjectPublications)
            }
    
            then:
            publications.publications.empty
        }
    
        def "project without any configured publications"() {
            buildFile << "apply plugin: 'java'"
    
            when:
            ProjectPublications publications = withConnection { connection ->
                connection.getModel(ProjectPublications)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 16 10:10:39 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go

    	// streams. newStreamHandler will be called asynchronously whenever the
    	// other end of the upgraded connection creates a new stream.
    	UpgradeResponse(w http.ResponseWriter, req *http.Request, newStreamHandler NewStreamHandler) Connection
    }
    
    // Connection represents an upgraded HTTP connection.
    type Connection interface {
    	// CreateStream creates a new Stream with the supplied headers.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  9. platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/connection/UnsupportedOlderVersionConnectionTest.groovy

            when:
            connection.run(GradleProject.class, parameters)
    
            then:
            UnsupportedVersionException e = thrown()
            e != null
        }
    
        def "partial BuildEnvironment"() {
            def connection = new UnsupportedOlderVersionConnection(connection, adapter)
    
            when:
            def buildEnv = connection.run(BuildEnvironment.class, parameters)
    
            then:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  10. subprojects/core/src/main/java/org/gradle/process/internal/worker/DefaultWorkerProcess.java

            }
        }
    
        public void onConnect(ObjectConnection connection) {
            onConnect(connection, null);
        }
    
        public void onConnect(ObjectConnection connection, Runnable connectionHandler) {
            AsyncStoppable stoppable;
            lock.lock();
            try {
                LOGGER.debug("Received connection {} from {}", connection, execHandle);
    
                if (connectionHandler != null && running) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jan 19 14:39:33 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top