Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 324 for dequeue (0.37 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top