- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 4,005 for Receive (0.21 sec)
-
docs/en/docs/tutorial/header-params.md
## Duplicate headers It is possible to receive duplicate headers. That means, the same header with multiple values. You can define those cases using a list in the type declaration. You will receive all the values from the duplicate header as a Python `list`.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Oct 17 05:59:11 UTC 2023 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
*/ @ExperimentalOkHttpApi interface AsyncDns { /** * Query DNS records for `hostname`, in the order they are received. */ fun query( hostname: String, callback: Callback, ) /** * Callback to receive results from the DNS Queries. */ @ExperimentalOkHttpApi interface Callback { /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
// client to fail at 1500ms when it's time to send ping 3 because pong 2 hasn't been received. taskFaker.advanceUntil(ns(1000L)) taskFaker.advanceUntil(ns(1500L)) client.listener.assertFailure( SocketTimeoutException::class.java, "sent ping but didn't receive pong within 500ms (after 1 successful ping/pongs)", ) } @Test
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/request/RequestArgumentSerializers.java
this.classLoader = classLoader; } @Override public Object read(Decoder decoder) throws Exception { return Message.receive(decoder.getInputStream(), classLoader); } @Override public void write(Encoder encoder, Object value) throws Exception { Message.send(value, encoder.getOutputStream()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Mar 15 22:51:06 UTC 2020 - 2K bytes - Viewed (0) -
apache-maven/src/main/appended-resources/META-INF/NOTICE.vm
conditions of the Eclipse Public License Version 1.0 ("EPL"). A copy of the EPL is available at http://www.eclipse.org/legal/epl-v10.html http://www.eclipse.org/legal/epl-v10.html. For purposes of the EPL, "Program" will mean the Content. If you did not receive this Content directly from the Eclipse Foundation, the Content is being redistributed by another party ("Redistributor") and different terms and conditions may apply to your use of any object code in the Content. Check the Redistributor's license...
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Sep 10 19:27:25 UTC 2022 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionSet.java
ConnectionState state = new ConnectionState(this, connection, queue); connections.add(state); return state; } /** * Called when all dispatch and receive has completed on the given connection. */ public void finished(ConnectionState connectionState) { connections.remove(connectionState); if (stopping) { maybeStop(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/StopDispatcher.java
public boolean dispatch(Connection<Message> connection, Command stopCommand) { Throwable failure = null; try { connection.dispatch(stopCommand); Result result = (Result) connection.receive(); if (result instanceof Failure) { failure = ((Failure) result).getValue(); } connection.dispatch(new Finished()); } catch (Throwable e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/WorkerProcess.java
import org.gradle.process.ExecResult; import org.gradle.process.internal.health.memory.JvmMemoryStatus; import java.util.Optional; /** * A child JVM that performs some worker action. You can send and receive messages to/from the worker action * using a supplied {@link ObjectConnection}. */ public interface WorkerProcess extends Describable { WorkerProcess start(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 19 21:45:01 UTC 2024 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/ReportStatusDispatcher.java
Status returnedStatus = null; Throwable failure = null; try { connection.dispatch(statusCommand); Result result = (Result) connection.receive(); if (result instanceof Failure) { failure = ((Failure) result).getValue(); } else if (result instanceof Success) { returnedStatus = (Status) result.getValue();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/sockcmsg_zos.go
h.Type = SCM_CREDENTIALS h.SetLen(CmsgLen(SizeofUcred)) *(*Ucred)(h.data(0)) = *ucred return b } // ParseUnixCredentials decodes a socket control message that contains // credentials in a Ucred structure. To receive such a message, the // SO_PASSCRED option must be enabled on the socket. func ParseUnixCredentials(m *SocketControlMessage) (*Ucred, error) { if m.Header.Level != SOL_SOCKET { return nil, EINVAL }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 16:12:58 UTC 2024 - 1.7K bytes - Viewed (0)