Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 228 for dequeue (0.04 sec)

  1. guava-testlib/src/com/google/common/collect/testing/testers/AbstractQueueTester.java

    @SuppressWarnings("JUnit4ClassUsedInJUnit3")
    public class AbstractQueueTester<E> extends AbstractCollectionTester<E> {
      protected final Queue<E> getQueue() {
        return (Queue<E>) collection;
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  2. docs/fr/docs/index.md

    * La documentation alternative reflétera également le nouveau paramètre de requête et le nouveau corps :
    
    ![ReDoc](https://fastapi.tiangolo.com/img/index/index-06-redoc-02.png)
    
    ### En résumé
    
    En résumé, vous déclarez **une fois** les types de paramètres, <abbr title="en anglais : body">le corps</abbr>  de la requête, etc. en tant que paramètres de fonction.
    
    Vous faites cela avec les types Python standard modernes.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 22K bytes
    - Viewed (0)
  3. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt

      override fun peek(): MockResponse = throw UnsupportedOperationException("unexpected call")
    
      fun enqueueResponse(response: MockResponse) {
        delegate.enqueue(response.wrap())
      }
    
      override fun shutdown() {
        delegate.close()
      }
    
      fun setFailFast(failFast: Boolean) {
        delegate.setFailFast(failFast)
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 14 16:09:26 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt

        startNs = queue.taskRunner.backend.nanoTime()
        log(task, queue, "starting")
      }
    
      var completedNormally = false
      try {
        val result = block()
        completedNormally = true
        return result
      } finally {
        if (loggingEnabled) {
          val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs
          if (completedNormally) {
            log(task, queue, "finished run in ${formatDuration(elapsedNs)}")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. samples/guide/src/main/java/okhttp3/recipes/kt/AsynchronousGet.kt

      private val client = OkHttpClient()
    
      fun run() {
        val request =
          Request
            .Builder()
            .url("http://publicobject.com/helloworld.txt")
            .build()
    
        client.newCall(request).enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              e.printStackTrace()
            }
    
            override fun onResponse(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  6. native-image-tests/src/test/kotlin/okhttp3/nativeimage/SampleTest.kt

      private val client = OkHttpClient()
    
      @Test
      fun passingTest() {
        assertThat("hello").isEqualTo("hello")
      }
    
      @Test
      fun testMockWebServer() {
        server.enqueue(MockResponse(body = "abc"))
        server.start()
    
        client.newCall(Request(url = server.url("/"))).execute().use {
          assertThat(it.body.string()).isEqualTo("abc")
        }
      }
    
      @Test
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 22 20:31:49 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  7. samples/guide/src/main/java/okhttp3/recipes/kt/DevServer.kt

    class DevServer {
      val handshakeCertificates = TlsUtil.localhost()
    
      val server =
        MockWebServer().apply {
          useHttps(handshakeCertificates.sslSocketFactory(), false)
    
          enqueue(
            MockResponse()
              .setResponseCode(HTTP_MOVED_TEMP)
              .setHeader("Location", "https://www.google.com/robots.txt"),
          )
        }
    
      val clientCertificates =
        HandshakeCertificates
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  8. samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt

      @StartStop
      private val server = MockWebServer()
    
      @BeforeEach fun setUp() {
        client.start()
      }
    
      @AfterEach fun tearDown() {
        client.stop()
      }
    
      @Test fun get() {
        server.enqueue(MockResponse(body = "hello, Jetty HTTP Client"))
    
        val request =
          client
            .newRequest(server.url("/").toUri())
            .header("Accept", "text/plain")
        val response = request.send()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  9. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

        unit: TimeUnit,
      ): RecordedRequest? = delegate.takeRequest(timeout, unit)?.unwrap()
    
      @JvmName("-deprecated_requestCount")
      fun getRequestCount(): Int = delegate.requestCount
    
      fun enqueue(response: MockResponse) {
        delegate.enqueue(response.wrap())
      }
    
      @Throws(IOException::class)
      @JvmOverloads
      fun start(port: Int = 0) {
        started = true
        delegate.start(port)
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 00:19:42 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

     * }
     * </pre>
     */
    public class ESSourceReader implements DocumentReader {
        private static final Logger logger = LogManager.getLogger(ESSourceReader.class);
    
        /** Queue of documents. */
        protected final Queue<Map<String, Object>> queue = new ConcurrentLinkedQueue<>();
        /** Flag indicating if reading is finished. */
        protected final AtomicBoolean isFinished = new AtomicBoolean(false);
        /** Random number generator. */
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 11K bytes
    - Viewed (0)
Back to top