- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 324 for dequeue (0.03 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/DefaultIntervalController.java
* and when waiting for new URLs. * The delays are configurable via constructor parameters. * */ public class DefaultIntervalController extends AbstractIntervalController { /** Delay in milliseconds after processing a URL */ protected long delayMillisAfterProcessing = 0L; /** Delay in milliseconds when no URL is in the queue */Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:58:39 UTC 2025 - 5.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingCookieJar.kt
*/ package okhttp3 import assertk.assertThat import assertk.assertions.containsExactly import java.util.ArrayDeque import java.util.Deque class RecordingCookieJar : CookieJar { private val requestCookies: Deque<List<Cookie>> = ArrayDeque() private val responseCookies: Deque<List<Cookie>> = ArrayDeque() fun enqueueRequestCookies(vararg cookies: Cookie) { requestCookies.add(cookies.toList()) }Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt
import kotlin.reflect.KClass import okio.Timeout open class FailingCall : Call { override fun request(): Request = error("unexpected") override fun execute(): Response = error("unexpected") override fun enqueue(responseCallback: Callback): Unit = error("unexpected") override fun cancel(): Unit = error("unexpected") override fun isExecuted(): Boolean = error("unexpected")Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 1.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/AbstractIntervalController.java
* <li>Before processing a URL ({@link #delayBeforeProcessing()})</li> * <li>After processing a URL ({@link #delayAfterProcessing()})</li> * <li>When there are no URLs in the queue ({@link #delayAtNoUrlInQueue()})</li> * <li>While waiting for new URLs to be added to the queue ({@link #delayForWaitingNewUrl()})</li> * </ul> * * <p> * Subclasses are responsible for implementing the abstract methods to define the actual delay
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:58:39 UTC 2025 - 4.8K bytes - Viewed (0) -
docs/fr/docs/alternatives.md
Il est conçu pour avoir des fonctions qui reçoivent deux paramètres, une "requête" et une "réponse". Ensuite, vous "lisez" des parties de la requête et "écrivez" des parties dans la réponse. En raison de cette conception, il n'est pas possible de déclarer des paramètres de requête et des corps avec des indications de type Python standard comme paramètres de fonction.
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 27.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/LoomTest.kt
} private fun newVirtualThreadPerTaskExecutor(): ExecutorService = Executors::class.java.getMethod("newVirtualThreadPerTaskExecutor").invoke(null) as ExecutorService @Test fun testRequest() { server.enqueue(MockResponse()) val request = Request(server.url("/")) client.newCall(request).execute().use { assertThat(it.code).isEqualTo(200) } } @Test fun testIfSupported() {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 2K bytes - Viewed (0) -
samples/compare/src/test/kotlin/okhttp3/compare/OkHttpClientTest.kt
*/ class OkHttpClientTest { @JvmField @RegisterExtension val platform = PlatformRule() @StartStop private val server = MockWebServer() @Test fun get() { server.enqueue(MockResponse(body = "hello, OkHttp")) val client = OkHttpClient() val request = Request .Builder() .url(server.url("/")) .header("Accept", "text/plain") .build()Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 1.9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/AsynchronousGet.java
public void run() throws Exception { Request request = new Request.Builder() .url("http://publicobject.com/helloworld.txt") .build(); client.newCall(request).enqueue(new Callback() { @Override public void onFailure(Call call, IOException e) { e.printStackTrace(); } @Override public void onResponse(Call call, Response response) throws IOException {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun May 22 01:29:42 UTC 2016 - 1.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
} server.useHttps(serverSslSocketFactory) } else if (socketMode == Channel) { socketFactory(ChannelSocketFactory()) } }.build() server.enqueue(MockResponse(body = "abc")) @Suppress("HttpUrlsUsage") val url = if (socketMode is TlsInstance) { "https://$hostname:${server.port}/get" } else {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 01 12:18:11 UTC 2025 - 7.9K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/ClientAndServer.java
MockWebServer server = new MockWebServer(); server.setServerSocketFactory(new UnixDomainServerSocketFactory(socketFile)); server.setProtocols(Collections.singletonList(Protocol.H2_PRIOR_KNOWLEDGE)); server.enqueue(new MockResponse().setBody("hello")); server.start(); OkHttpClient client = new OkHttpClient.Builder() .socketFactory(new UnixDomainSocketFactory(socketFile))Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Dec 24 03:46:30 UTC 2018 - 2.1K bytes - Viewed (0)