Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 318 for dequeue (0.04 seconds)

  1. 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.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Oct 01 13:14:50 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  2. 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")
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  3. docs/fr/docs/advanced/wsgi.md

    Assurez-vous simplement que le package `a2wsgi` est installé et importez `WSGIMiddleware` correctement depuis `a2wsgi`.
    
    ///
    
    ## Vérifiez { #check-it }
    
    Désormais, chaque requête sous le chemin `/v1/` sera gérée par l'application Flask.
    
    Et le reste sera géré par **FastAPI**.
    
    Si vous l'exécutez et allez à [http://localhost:8000/v1/](http://localhost:8000/v1/) vous verrez la réponse de Flask :
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 1.6K bytes
    - Click Count (0)
  4. 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
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jun 08 16:12:05 GMT 2025
    - 972 bytes
    - Click Count (0)
  5. 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()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  6. 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 {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun May 22 01:29:42 GMT 2016
    - 1.9K bytes
    - Click Count (0)
  7. 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() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 2K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/core/misc/DisposableUtil.java

    import static org.codelibs.core.collection.CollectionsUtil.newLinkedList;
    import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull;
    
    import java.beans.Introspector;
    import java.util.Deque;
    
    /**
     * Utility class for disposing of resources at the end of an application.
     * <p>
     * If there are resources that must be disposed of at the end of the application,
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Feb 12 12:10:45 GMT 2026
    - 3.1K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/collect/EvictingQueue.java

    import java.util.Collection;
    import java.util.Queue;
    
    /**
     * A non-blocking queue which automatically evicts elements from the head of the queue when
     * attempting to add new elements onto the queue and it is full. This queue orders elements FIFO
     * (first-in-first-out). This data structure is logically equivalent to a circular buffer (i.e.,
     * cyclic buffer or ring buffer).
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        assertEquals(6, queue.size());
        assertEquals(8, queue.capacity());
        checkUnbounded(queue);
        checkNatural(queue);
      }
    
      public void testCreation_maximumSize_withContents() {
        MinMaxPriorityQueue<Integer> queue =
            rawtypeToWildcard(MinMaxPriorityQueue.maximumSize(42)).create(NUMBERS);
        assertEquals(6, queue.size());
        assertEquals(11, queue.capacity());
        assertEquals(42, queue.maximumSize);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 36.2K bytes
    - Click Count (0)
Back to Top