Search Options

Results per page
Sort
Preferred Languages
Advance

Results 531 - 540 of 770 for NEXT (0.05 sec)

  1. guava-tests/test/com/google/common/collect/AbstractImmutableSetTest.java

          this.infiniteCandidates = infiniteCandidates.iterator();
        }
    
        @Override
        protected Set<E> delegate() {
          return infiniteCandidates.next();
        }
      }
    
      private static final class MutatedOnQueryList<E> extends ForwardingList<E> {
        final Iterator<ImmutableList<E>> infiniteCandidates;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      public void testSimpleWithWait() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        limiter.acquire(); // R0.00
        stopwatch.sleepMillis(200); // U0.20, we are ready for the next request...
        limiter.acquire(); // R0.00, ...which is granted immediately
        limiter.acquire(); // R0.20
        assertEvents("R0.00", "U0.20", "R0.00", "R0.20");
      }
    
      public void testSimpleAcquireReturnValues() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      public void testSimpleWithWait() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        limiter.acquire(); // R0.00
        stopwatch.sleepMillis(200); // U0.20, we are ready for the next request...
        limiter.acquire(); // R0.00, ...which is granted immediately
        limiter.acquire(); // R0.20
        assertEvents("R0.00", "U0.20", "R0.00", "R0.20");
      }
    
      public void testSimpleAcquireReturnValues() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/AndXServerMessageBlock.java

             * response will not read a batched command and therefore
             * the 'received' member of the response object will not
             * be set to true indicating the send and sendTransaction
             * methods that the next part should be sent. This is a
             * very indirect and simple batching control mechanism.
             */
    
            if( andx == null || USE_BATCHING == false ||
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 11.3K bytes
    - Viewed (0)
  5. cmd/benchmark-utils_test.go

    	b.ReportAllocs()
    	// the actual benchmark for PutObject starts here. Reset the benchmark timer.
    	b.ResetTimer()
    
    	b.RunParallel(func(pb *testing.PB) {
    		i := 0
    		for pb.Next() {
    			// insert the object.
    			objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i),
    				mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 23 15:46:00 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/ImmutableCollection.java

       *
       * @since 2.0
       */
      public ImmutableList<E> asList() {
        switch (size()) {
          case 0:
            return ImmutableList.of();
          case 1:
            return ImmutableList.of(iterator().next());
          default:
            return new RegularImmutableAsList<>(this, toArray());
        }
      }
    
      /**
       * Returns {@code true} if this immutable collection's implementation contains references to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 12 16:59:15 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/Queues.java

       * ...
       * synchronized (queue) {  // Must synchronize on queue!
       *   Iterator<E> i = queue.iterator(); // Must be in synchronized block
       *   while (i.hasNext()) {
       *     foo(i.next());
       *   }
       * }
       * }</pre>
       *
       * <p>Failure to follow this advice may result in non-deterministic behavior.
       *
       * <p>The returned queue will be serializable if the specified queue is serializable.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

            override fun runOnce(): Long {
              block()
              return -1L
            }
          },
          delayNanos,
        )
      }
    
      /** Returns a latch that reaches 0 when the queue is next idle. */
      fun idleLatch(): CountDownLatch {
        taskRunner.lock.withLock {
          // If the queue is already idle, that's easy.
          if (activeTask == null && futureTasks.isEmpty()) {
            return CountDownLatch(0)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/RegularContiguousSet.java

          final C last = last();
    
          @Override
          @CheckForNull
          protected C computeNext(C previous) {
            return equalsOrThrow(previous, last) ? null : domain.next(previous);
          }
        };
      }
    
      @GwtIncompatible // NavigableSet
      @Override
      public UnmodifiableIterator<C> descendingIterator() {
        return new AbstractSequentialIterator<C>(last()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/collect/testing/testers/NavigableSetNavigationTester.java

      @CollectionSize.Require(SEVERAL)
      public void testDescendingNavigation() {
        List<E> descending = new ArrayList<>();
        for (Iterator<E> i = navigableSet.descendingIterator(); i.hasNext(); ) {
          descending.add(i.next());
        }
        Collections.reverse(descending);
        assertEquals(values, descending);
      }
    
      public void testEmptySubSet() {
        NavigableSet<E> empty = navigableSet.subSet(e0(), false, e0(), false);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top