- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 4,005 for Receive (0.12 sec)
-
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/BuildProgressCrossVersionSpec.groovy
ex.causes == [failure] and: "expected events received" resultsOfFirstListener.size() == 1 resultsOfLastListener.size() == 1 and: "build execution is successful" assertHasBuildSuccessfulLogging() } def "receive build progress events for successful operations"() { given: goodCode() when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 7.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultIncomingConnectionHandler.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 7K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformWithFileInputsIntegrationTest.groovy
output.text = input.text + paramContent + ".green" } } """ } def "transform can receive a file collection containing pre-built files via parameter object"() { createDirs("a", "b", "c") settingsFile << """ include 'a', 'b', 'c' """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 20.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/ReportDaemonStatusClientTest.groovy
1 * connection.receive() >> new Success(new Status(12345, "3.0", "BOGUS")) 1 * connection.dispatch({it instanceof Finished}) 1 * connection.stop() and: 1 * connector.maybeConnect(daemon2) >>> connection _ * connection.daemon >> daemon2 1 * connection.dispatch({it instanceof ReportStatus}) 1 * connection.receive() >> new Success(new Status(12346, "3.0", "BOGUS"))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4.7K bytes - Viewed (0) -
subprojects/build-events/src/main/java/org/gradle/build/event/BuildEventsListenerRegistry.java
* limitations under the License. */ package org.gradle.build.event; import org.gradle.api.provider.Provider; import org.gradle.tooling.events.OperationCompletionListener; /** * Allows a plugin to receive information about the operations that run within a build. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 30 09:10:51 UTC 2022 - 2.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/TestConnection.groovy
@Override void flush() { outgoingBuffered.drainTo(outgoing) } @Override InterHubMessage receive() { def message = incoming.take() return message == END ? null : (InterHubMessage) message } /** * Queues the given message to return from {@link #receive()}. */ void queueIncoming(InterHubMessage message) { incoming.put(message) } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.8K bytes - Viewed (0) -
SECURITY.md
you need access credentials for a successful exploit). If you have not received a reply to your email within 48 hours or you have not heard from the security team for the past five days please contact the security team directly: - Primary security coordinator: ******@****.*** - Secondary coordinator: ******@****.*** - If you receive no response: ******@****.*** ### Disclosure Process MinIO uses the following disclosure process:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Feb 12 00:51:25 UTC 2022 - 2.2K bytes - Viewed (0) -
test/const4.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jul 11 14:36:33 UTC 2015 - 1.3K bytes - Viewed (0) -
src/runtime/export_unix_test.go
} // WaitForSigusr1 blocks until a SIGUSR1 is received. It calls ready // when it is set up to receive SIGUSR1. The ready function should // cause a SIGUSR1 to be sent. The r and w arguments are a pipe that // the signal handler can use to report when the signal is received. // // Once SIGUSR1 is received, it returns the ID of the current M and // the ID of the M the SIGUSR1 was received on. If the caller writes
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 20 21:27:51 UTC 2023 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher.go
select { case <-sw.done: default: close(sw.done) sw.source.Close() } } // receive reads result from the decoder in a loop and sends down the result channel. func (sw *StreamWatcher) receive() { defer utilruntime.HandleCrash() defer close(sw.result) defer sw.Stop() for { action, obj, err := sw.source.Decode() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 06 13:42:59 UTC 2021 - 3.9K bytes - Viewed (0)