- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 4,005 for Receive (0.15 sec)
-
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) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
import org.gradle.internal.dispatch.Receive; /** * <p>A messaging endpoint which allows push-style dispatch and pull-style receive. * * <p>Implementations are not guaranteed to be completely thread-safe. * However, the implementations: * <ul> * <li>should allow separate threads for dispatching and receiving, i.e. single thread that dispatches * and a different single thread that receives should be perfectly safe</li>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientTest.groovy
1 * connection.dispatch({ it instanceof Build }) 1 * connection.receive() >> Stub(DaemonUnavailable) 1 * connection.dispatch({ it instanceof Finished }) 1 * connection.stop() _ * connection2.daemon >> Stub(DaemonConnectDetails) 2 * connection2.receive() >>> [Stub(BuildStarted), new Success(resultMessage)] 0 * connection._ }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 10K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/resolver/KotlinBuildScriptModelRepositoryTest.kt
) // now we expect to receive the most recent request since the last request that got a response, // that's the last request in our list of pending tasks val (reqLast, asyncRespLast) = pendingTasks.last() assertThat( pendingRequest.receive(), sameInstance(reqLast) ) // submit the second (and last) response
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 6.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/inet/TcpConnectorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 10.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/SynchronizedDispatchConnection.java
} finally { lock.unlock(); } } @Override public T receive() { //in case one wants to synchronize this method, //bear in mind that it is blocking so it cannot share the same lock as others T result = delegate.receive(); LOGGER.debug("thread {}: received {}", Thread.currentThread().getId(), result == null ? "null" : result.getClass()); return result; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 3K bytes - Viewed (0)