- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 228 for dequeue (0.03 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt
* * @throws IllegalStateException when the call has already been executed. */ fun enqueue(responseCallback: Callback) /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */ fun cancel() /** * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an * error to execute a call more than once. */ fun isExecuted(): Boolean
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.6K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/HttpsServer.java
.heldCertificate(localhostCertificate) .build(); MockWebServer server = new MockWebServer(); server.useHttps(serverCertificates.sslSocketFactory(), false); server.enqueue(new MockResponse()); HandshakeCertificates clientCertificates = new HandshakeCertificates.Builder() .addTrustedCertificate(localhostCertificate.certificate()) .build();
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jan 02 14:04:37 UTC 2023 - 2.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java
import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; import com.google.common.util.concurrent.ListenableFuture; import java.util.ArrayDeque; import java.util.Deque; import java.util.Map; import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 3.6K bytes - Viewed (0) -
samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt
@Test fun get() { // Not available platform.expectFailureOnJdkVersion(8) val httpClient = HttpClient .newBuilder() .followRedirects(NORMAL) .build() server.enqueue( MockResponse .Builder() .body("hello, Java HTTP Client") .build(), ) val request = HttpRequest .newBuilder(server.url("/").toUri())
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 2.8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java
.build(); public void run() throws Exception { Request washingtonPostRequest = new Request.Builder() .url("https://www.washingtonpost.com/") .build(); client.newCall(washingtonPostRequest).enqueue(new Callback() { @Override public void onFailure(Call call, IOException e) { } @Override public void onResponse(Call call, Response response) throws IOException {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 16 23:20:49 UTC 2020 - 6.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
/** Asynchronously writes frames to the outgoing socket. */ private val writerQueue = taskRunner.newQueue() /** Ensures push promise callbacks events are sent in order per stream. */ private val pushQueue = taskRunner.newQueue() /** Notifies the listener of settings changes. */ private val settingsListenerQueue = taskRunner.newQueue() /** User code to run in response to push promise events. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 31.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/TearDownStack.java
import com.google.common.annotations.VisibleForTesting; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Deque; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; import org.jspecify.annotations.NullMarked; /** * A {@code TearDownStack} contains a stack of {@link TearDown} instances.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 2.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/TearDownStack.java
import com.google.common.annotations.VisibleForTesting; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Deque; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; import org.jspecify.annotations.NullMarked; /** * A {@code TearDownStack} contains a stack of {@link TearDown} instances.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 2.5K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceFactoryTest.java
@Test public void testEventSourceFactory() throws Exception { OkHttpClient client = new OkHttpClient(); EventSource.Factory factory = EventSource.Factory.create(client); server.enqueue( new MockResponse.Builder() .body("data: hello\n\n") .setHeader("content-type", "text/event-stream") .build() ); Request request = new Request.Builder().url(server.url("/")).build();
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 2.8K bytes - Viewed (0) -
buildscripts/cross-compile.sh
printf -- "--> %15s:%s\n" "${osarch}" "${package}" # go build -trimpath to build the binary. export GOOS=$os export GOARCH=$arch export GO111MODULE=on go build -trimpath -tags kqueue -o /dev/null } function main() { echo "Testing builds for OS/Arch: ${SUPPORTED_OSARCH}" for each_osarch in ${SUPPORTED_OSARCH}; do _build "${each_osarch}" done }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Jun 08 16:12:05 UTC 2025 - 972 bytes - Viewed (0)