- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,076 for Receive (0.13 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/Receive.java
* A source for messages. Implementations do not have to be thread-safe. */ public interface Receive<T> { /** * Blocks until the next message is available. Returns null when the end of the message stream has been reached. * * @return The next message, or null when the end of the stream has been reached. */ @Nullable T receive();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DefaultDaemonConnectionTest.groovy
def result = [] result << daemonConnection.receive(20, TimeUnit.SECONDS) result << daemonConnection.receive(20, TimeUnit.SECONDS) result << daemonConnection.receive(20, TimeUnit.SECONDS) daemonConnection.stop() then: result*.message == ["incoming1", "incoming2", "incoming3"] } def "receive blocks until message available"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientConnectionTest.groovy
0 * staleAddressDetector._ } def "handles failed receive"() { def failure = new FooException() given: 1 * delegate.receive() >> Stub(Message) delegate.receive() >> { throw failure } when: connection.receive() connection.receive() then: def ex = thrown(DaemonConnectionException)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.8K bytes - Viewed (0) -
platforms/core-configuration/declarative-dsl-provider/src/main/kotlin/org/gradle/internal/declarativedsl/conventions/conventions.kt
} } /** * A convention that applies a nested object access operation (e.g. foo { }). */ class NestedObjectAccessConvention(private val nestedObjectAccessRecord: NestedObjectAccessRecord) : Convention<NestedObjectAccessRecordConventionReceiver> { override fun apply(receiver: NestedObjectAccessRecordConventionReceiver) { receiver.receive(nestedObjectAccessRecord) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 12:25:47 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockCommunicatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/proxy/util/utils_test.go
expectCorrect: nil, expectIncorrect: nil, }, { desc: "want IPv4 and receive IPv6", ipString: []string{"fd00:20::1"}, wantIPv6: false, expectCorrect: nil, expectIncorrect: []string{"fd00:20::1"}, }, { desc: "want IPv6 and receive IPv4", ipString: []string{"192.168.200.2"}, wantIPv6: true, expectCorrect: nil,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 17.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/ReportStatusDispatcherTest.groovy
def "ignores failed dispatch and does not receive"() { given: def message = new ReportStatus(UUID.randomUUID(), "TOKEN".bytes) connection.dispatch(message) >> { throw new RuntimeException("Cannot dispatch") } when: dispatcher.dispatch(connection, message) then: 0 * connection.receive() noExceptionThrown() }
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
def "ignores failed dispatch and does not receive"() { given: def message = new Stop(UUID.randomUUID()) connection.dispatch(message) >> { throw new RuntimeException("Cannot dispatch") } when: dispatcher.dispatch(connection, message) then: 0 * connection.receive() noExceptionThrown() } def "ignores failed receive"() { given:
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/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonStopClientTest.groovy
1 * connection.receive() >> new Success(null) 1 * connection.dispatch({it instanceof Finished}) 1 * connection.stop() and: 1 * connector.maybeConnect(daemon2) >>> connection _ * connection.daemon >> daemon2 1 * connection.dispatch({it instanceof StopWhenIdle}) 1 * connection.receive() >> new Success(null)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.7K bytes - Viewed (0) -
docs/en/docs/tutorial/request-forms-and-files.md
``` The files and form fields will be uploaded as form data and you will receive the files and form fields. And you can declare some of the files as `bytes` and some as `UploadFile`. !!! warning
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Mar 13 19:02:19 UTC 2024 - 2K bytes - Viewed (0)