Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 109 for dequeue (0.15 sec)

  1. okhttp-coroutines/src/test/kotlin/okhttp3/SuspendCallTest.kt

      @Test
      fun suspendCall() {
        runTest {
          server.enqueue(MockResponse(body = "abc"))
    
          val call = client.newCall(request)
    
          call.executeAsync().use {
            withContext(Dispatchers.IO) {
              assertThat(it.body.string()).isEqualTo("abc")
            }
          }
        }
      }
    
      @Test
      fun timeoutCall() {
        runTest {
          server.enqueue(
            MockResponse.Builder()
    Plain Text
    - Registered: Fri Apr 12 11:42:09 GMT 2024
    - Last Modified: Fri Apr 05 11:25:23 GMT 2024
    - 5.3K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.Currency;
    import java.util.Deque;
    import java.util.Iterator;
    import java.util.List;
    import java.util.ListIterator;
    import java.util.Locale;
    import java.util.Map;
    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Optional;
    import java.util.OptionalDouble;
    import java.util.OptionalInt;
    import java.util.OptionalLong;
    import java.util.Queue;
    import java.util.Random;
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 21K bytes
    - Viewed (1)
  3. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.Collection;
    import java.util.Comparator;
    import java.util.Currency;
    import java.util.Deque;
    import java.util.Iterator;
    import java.util.List;
    import java.util.ListIterator;
    import java.util.Locale;
    import java.util.Map;
    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 20.5K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/CacheTest.kt

      @Test
      fun redirectToCachedResult() {
        server.enqueue(
          MockResponse.Builder()
            .addHeader("Cache-Control: max-age=60")
            .body("ABC")
            .build(),
        )
        server.enqueue(
          MockResponse.Builder()
            .code(HttpURLConnection.HTTP_MOVED_PERM)
            .addHeader("Location: /foo")
            .build(),
        )
        server.enqueue(
          MockResponse.Builder()
            .body("DEF")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 108.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Iterables.java

       *
       * <p>Note: If {@code iterable} is a {@link Queue}, the returned iterable will instead use {@link
       * Queue#isEmpty} and {@link Queue#remove()}, since {@link Queue}'s iteration order is undefined.
       * Calling {@link Iterator#hasNext()} on a generated iterator from the returned iterable may cause
       * an item to be immediately dequeued for return on a subsequent call to {@link Iterator#next()}.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 24 19:38:27 GMT 2024
    - 42.8K bytes
    - Viewed (0)
  6. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

      @Test
      fun suspendCall() {
        runTest {
          server.enqueue(MockResponse(body = "abc"))
    
          val call = client.newCall(request)
    
          call.executeAsync().use {
            withContext(Dispatchers.IO) {
              assertThat(it.body.string()).isEqualTo("abc")
            }
          }
        }
      }
    
      @Test
      fun timeoutCall() {
        runTest {
          server.enqueue(
            MockResponse.Builder()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:24:38 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  7. 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);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Mar 07 18:34:03 GMT 2024
    - 36.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/LocalCacheTest.java

            ReferenceEntry<Object, Object> entry = segment.getEntry(keyOne, hashOne);
    
            @SuppressWarnings("unchecked")
            Reference<Object> reference = (Reference<Object>) entry;
            reference.enqueue();
    
            map.put(keyTwo, valueTwo);
            assertFalse(map.containsKey(keyOne));
            assertFalse(map.containsValue(valueOne));
            assertNull(map.get(keyOne));
            assertEquals(1, map.size());
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 112.3K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

            ReferenceEntry<Object, Object> entry = segment.getEntry(keyOne, hashOne);
    
            @SuppressWarnings("unchecked")
            Reference<Object> reference = (Reference<Object>) entry;
            reference.enqueue();
    
            map.put(keyTwo, valueTwo);
            assertFalse(map.containsKey(keyOne));
            assertFalse(map.containsValue(valueOne));
            assertNull(map.get(keyOne));
            assertEquals(1, map.size());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 110.7K bytes
    - Viewed (0)
  10. Makefile

    lint: getdeps ## runs golangci-lint suite of linters
    	@echo "Running $@ check"
    	@$(GOLANGCI) run --build-tags kqueue --timeout=10m --config ./.golangci.yml
    
    lint-fix: getdeps ## runs golangci-lint suite of linters with automatic fixes
    	@echo "Running $@ check"
    	@$(GOLANGCI) run --build-tags kqueue --timeout=10m --config ./.golangci.yml --fix
    
    check: test
    test: verifiers build build-debugging ## builds minio, runs linters, tests
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:55:41 GMT 2024
    - 10.3K bytes
    - Viewed (1)
Back to top