Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 112 for dedupe (0.02 sec)

  1. src/main/java/jcifs/SmbResourceException.java

            case LOCK:
                return "Release existing locks or wait for them to be released";
            case BUFFER:
                return "Reduce buffer usage or increase buffer pool size";
            case THREAD_POOL:
                return "Reduce concurrent operations or increase thread pool size";
            default:
                return "Check resource availability and retry";
            }
        }
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  2. 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<>();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  3. 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<>();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  4. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  5. okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt

    import assertk.assertions.isEqualTo
    import java.util.ArrayDeque
    import java.util.Deque
    import okio.Buffer
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Test
    
    class ServerSentEventIteratorTest {
      /** Either [Event] or [Long] items for events and retry changes, respectively.  */
      private val callbacks: Deque<Any> = ArrayDeque()
    
      @AfterEach
      fun after() {
        assertThat(callbacks).isEmpty()
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. 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;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  7. 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.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 01 13:14:50 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  8. 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.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 01 13:14:50 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  9. 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,
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 3K bytes
    - Viewed (0)
  10. android/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;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 3.8K bytes
    - Viewed (0)
Back to top