Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 798 for NEXT (0.03 sec)

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

          SortedSet<@Nullable Object> self = (SortedSet<@Nullable Object>) this;
          Iterator<?> iterator = self.tailSet(object).iterator();
          if (iterator.hasNext()) {
            Object ceiling = iterator.next();
            if (unsafeCompare(comparator(), ceiling, object) == 0) {
              iterator.remove();
              return true;
            }
          }
        } catch (ClassCastException | NullPointerException e) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 15:26:39 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java

        }
    
        // ensures that the number of invocations looks sane
        void assertInvariants(int expectedBytes) {
          // we should have seen as many bytes as the next multiple of chunk after expectedBytes - 1
          assertEquals(out.toByteArray().length, ceilToMultiple(expectedBytes, chunkSize));
          assertEquals(expectedBytes / chunkSize, processCalled);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/collect/testing/testers/MapPutAllTester.java

            ConcurrentModificationException.class,
            () -> {
              Iterator<Entry<K, V>> iterator = getMap().entrySet().iterator();
              putAll(MinimalCollection.of(e3(), e0()));
              iterator.next();
            });
      }
    
      @MapFeature.Require(absent = SUPPORTS_PUT)
      @CollectionSize.Require(absent = ZERO)
      public void testPutAll_unsupportedSomePresent() {
        assertThrows(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. src/archive/tar/writer.go

    	fileState
    
    	ReadFrom(io.Reader) (int64, error)
    }
    
    // Flush finishes writing the current file's block padding.
    // The current file must be fully written before Flush can be called.
    //
    // This is unnecessary as the next call to [Writer.WriteHeader] or [Writer.Close]
    // will implicitly flush out the file's padding.
    func (tw *Writer) Flush() error {
    	if tw.err != nil {
    		return tw.err
    	}
    	if nb := tw.curr.logicalRemaining(); nb > 0 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/Trans2FindFirst2Response.java

                 * or to the start of the entry containing the
                 * filename(e.g. NT). Ahhrg! In either case the
                 * lastNameOffset falls between the start of the
                 * entry and the next entry.
                 */
    
                if( lastNameBufferIndex >= bufferIndex && ( e.nextEntryOffset == 0 ||
                            lastNameBufferIndex < ( bufferIndex + e.nextEntryOffset ))) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 8.5K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    				return
    			}
    			var next []byte
    			next, remain, err = msgp.ReadBytesZC(remain)
    			if err != nil {
    				if !xnet.IsNetworkOrHostDown(err, true) {
    					gridLogIf(ctx, fmt.Errorf("ws read merged: %w", err))
    				}
    				return
    			}
    
    			m.Payload = nil
    			subID, _, err = m.parse(next)
    			if err != nil {
    				if !xnet.IsNetworkOrHostDown(err, true) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

        val executableCalls = mutableListOf<AsyncCall>()
        val isRunning: Boolean
        this.withLock {
          val i = readyAsyncCalls.iterator()
          while (i.hasNext()) {
            val asyncCall = i.next()
    
            if (runningAsyncCalls.size >= this.maxRequests) break // Max capacity.
            if (asyncCall.callsPerHost.get() >= this.maxRequestsPerHost) continue // Host max capacity.
    
            i.remove()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/search/SearchAction.java

            }
            return doSearch(form);
        }
    
        @Execute
        public HtmlResponse prev(final SearchForm form) {
            return doMove(form, -1);
        }
    
        @Execute
        public HtmlResponse next(final SearchForm form) {
            return doMove(form, 1);
        }
    
        @Execute
        public HtmlResponse move(final SearchForm form) {
            return doMove(form, 0);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 12.3K bytes
    - Viewed (0)
Back to top