- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 1,340 for connector (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)