Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 36 for deque (0.02 seconds)

  1. guava/src/com/google/common/collect/Queues.java

       *
       * @param deque the deque to be wrapped in a synchronized view
       * @return a synchronized view of the specified deque
       * @since 15.0
       */
      @J2ktIncompatible // Synchronized
      public static <E extends @Nullable Object> Deque<E> synchronizedDeque(Deque<E> deque) {
        return Synchronized.deque(deque, null);
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 18K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/Queues.java

       *
       * @param deque the deque to be wrapped in a synchronized view
       * @return a synchronized view of the specified deque
       * @since 15.0
       */
      @J2ktIncompatible // Synchronized
      public static <E extends @Nullable Object> Deque<E> synchronizedDeque(Deque<E> deque) {
        return Synchronized.deque(deque, null);
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

          if (connection.noNewExchanges) {
            assertThat(eventSequence).matchesPredicate { deque ->
              deque.any { it is NoNewExchanges && it.connection == connection }
            }
          }
        }
    
        logEvent(ConnectionEvent.ConnectionReleased(System.nanoTime(), connection, call))
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri May 30 21:28:20 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

      protected Deque<String> create() {
        TestDeque<String> inner = new TestDeque<>();
        Deque<String> outer = Synchronized.deque(inner, inner.mutex);
        outer.add("foo"); // necessary because we try to remove elements later on
        return outer;
      }
    
      private static final class TestDeque<E> implements Deque<E> {
        private final Deque<E> delegate = new LinkedList<>();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

      protected Deque<String> create() {
        TestDeque<String> inner = new TestDeque<>();
        Deque<String> outer = Synchronized.deque(inner, inner.mutex);
        outer.add("foo"); // necessary because we try to remove elements later on
        return outer;
      }
    
      private static final class TestDeque<E> implements Deque<E> {
        private final Deque<E> delegate = new LinkedList<>();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  6. 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())
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  7. fastapi/encoders.py

    import dataclasses
    import datetime
    from collections import defaultdict, deque
    from decimal import Decimal
    from enum import Enum
    from ipaddress import (
        IPv4Address,
        IPv4Interface,
        IPv4Network,
        IPv6Address,
        IPv6Interface,
        IPv6Network,
    )
    from pathlib import Path, PurePath
    from re import Pattern
    from types import GeneratorType
    from typing import Annotated, Any, Callable, Optional, Union
    from uuid import UUID
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 10.7K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/cache/CacheLoaderTest.java

    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.ImmutableMap;
    import com.google.common.util.concurrent.ListenableFuture;
    import java.util.ArrayDeque;
    import java.util.Deque;
    import java.util.Map;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  9. fastapi/_compat/shared.py

    PYDANTIC_V2 = PYDANTIC_VERSION_MINOR_TUPLE[0] == 2
    
    
    sequence_annotation_to_type = {
        Sequence: list,
        list: list,
        tuple: tuple,
        set: set,
        frozenset: frozenset,
        deque: deque,
    }
    
    sequence_types = tuple(sequence_annotation_to_type.keys())
    
    Url: type[Any]
    
    
    # Copy of Pydantic v2, compatible with v1
    def lenient_issubclass(
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  10. android/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 Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 01 13:14:50 GMT 2025
    - 2.7K bytes
    - Click Count (0)
Back to Top