Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for Deque (0.04 sec)

  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);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/collect/ForwardingDequeTest.java

                  public Deque<?> apply(Deque delegate) {
                    return wrap((Deque<?>) delegate);
                  }
                });
      }
    
      private static <T> Deque<T> wrap(final Deque<T> delegate) {
        return new ForwardingDeque<T>() {
          @Override
          protected Deque<T> delegate() {
            return delegate;
          }
        };
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 20:09:59 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. 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);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        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 = Lists.newLinkedList();
        public final Object mutex = new Object[0]; // something Serializable
    
        @Override
        public boolean offer(E o) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  5. 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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  6. 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))
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (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 Any, Callable, Dict, List, Optional, Tuple, Type, Union
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 21:56:59 UTC 2024
    - 10.8K bytes
    - Viewed (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.collect.Queues;
    import com.google.common.util.concurrent.ListenableFuture;
    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;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/core/misc/DisposableUtil.java

    import java.beans.Introspector;
    import java.util.Deque;
    
    /**
     * アプリケーションの終了時にリソースを破棄するためのユーティリティクラスです。
     * <p>
     * アプリケーションの終了時に破棄しなければならないリソースがある場合は、 {@link Disposable}を実装したクラスを作成し、
     * このクラスに登録します。
     * </p>
     *
     * @author koichik
     */
    public abstract class DisposableUtil {
    
        /** 登録済みの{@link Disposable} */
        protected static final Deque<Disposable> disposables = newLinkedList();
    
        /**
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/tls/BasicCertificateChainCleaner.kt

     */
    package okhttp3.internal.tls
    
    import java.security.GeneralSecurityException
    import java.security.cert.Certificate
    import java.security.cert.X509Certificate
    import java.util.ArrayDeque
    import java.util.Deque
    import javax.net.ssl.SSLPeerUnverifiedException
    
    /**
     * A certificate chain cleaner that uses a set of trusted root certificates to build the trusted
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.8K bytes
    - Viewed (0)
Back to top