Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 320 for immediately (0.07 seconds)

  1. android/guava/src/com/google/common/escape/UnicodeEscaper.java

       *
       * <p>See {@link com.google.common.net.PercentEscaper} for an example.
       *
       * @param csq a sequence of characters
       * @param start the index of the first character to be scanned
       * @param end the index immediately after the last character to be scanned
       * @throws IllegalArgumentException if the scanned sub-sequence of {@code csq} contains invalid
       *     surrogate pairs
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Jan 24 04:06:11 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

        // need to handle RejectedExecutionException
    
        if (allMustSucceed) {
          // We need fail fast, so we have to keep track of which future failed so we can propagate
          // the exception immediately
    
          // Register a listener on each Future in the list to update the state of this future.
          // Note that if all the futures on the list are done prior to completing this loop, the last
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 16K bytes
    - Click Count (0)
  3. src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java

                assertThrows(IOException.class, () -> sis.read(buffer, 0, 10));
            } catch (IOException e) {
                // This is also acceptable - if the implementation tries to read
                // the next header immediately after consuming all data
                assertTrue(e.getMessage().contains("unexpected EOF"));
            }
        }
    
        @Test
        @DisplayName("Zero-length message is handled correctly")
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            });
        assertThat(orig.toString())
            .contains("Exception thrown from implementation: class java.lang.StackOverflowError");
      }
    
      // Regression test for a case where we would fail to execute listeners immediately on done futures
      // this would be observable from an afterDone callback
      public void testListenersExecuteImmediately_fromAfterDone() {
        AbstractFuture<String> f =
            new AbstractFuture<String>() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  5. android/guava-testlib/src/com/google/common/collect/testing/Helpers.java

        sort(insertionOrder, entryComparator(keyComparator));
        return insertionOrder;
      }
    
      /**
       * Compares strings in natural order except that null comes immediately before a given value. This
       * works better than Ordering.natural().nullsFirst() because, if null comes before all other
       * values, it lies outside the submap/submultiset ranges we test, and the variety of tests that
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 17.2K bytes
    - Click Count (0)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt

            "invalid interval: $notBefore..$notAfter"
          }
          this.notBefore = notBefore
          this.notAfter = notAfter
        }
    
        /**
         * Sets the certificate to be valid immediately and until the specified duration has elapsed.
         * The precision of this field is seconds; further precision will be truncated.
         */
        fun duration(
          duration: Long,
          unit: TimeUnit,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 21.6K bytes
    - Click Count (0)
  7. cmd/endpoint.go

    		// Break if the local endpoint is found already Or all the endpoints are resolved.
    
    		// Retry infinitely on Kubernetes and Docker swarm.
    		// This is needed as the remote hosts are sometime
    		// not available immediately.
    		select {
    		case <-globalOSSignalCh:
    			return fmt.Errorf("The endpoint resolution got interrupted")
    		default:
    			for i, resolved := range resolvedList {
    				if resolved {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  8. compat/maven-artifact/src/main/java/org/apache/maven/artifact/versioning/VersionRange.java

                // original recommended version
                version = restriction.recommendedVersion;
            }
            /* TODO should throw this immediately, but need artifact
                    else
                    {
                        throw new OverConstrainedVersionException( "Restricting incompatible version ranges" );
                    }
            */
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 19K bytes
    - Click Count (0)
  9. cmd/background-newdisks-heal-ops.go

    			if len(healDisks) == 0 {
    				// Reset for next interval.
    				diskCheckTimer.Reset(defaultMonitorNewDiskInterval)
    				continue
    			}
    
    			// Reformat disks immediately
    			_, err := z.HealFormat(context.Background(), false)
    			if err != nil && !errors.Is(err, errNoHealRequired) {
    				healingLogIf(ctx, err)
    				// Reset for next interval.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/collect/MultimapsCollectionTest.java

        static <K, V> PopulatableMapAsMultimap<K, V> create() {
          return new PopulatableMapAsMultimap<>();
        }
    
        @SuppressWarnings("unchecked") // all methods throw immediately
        PopulatableMapAsMultimap() {
          this.map = new HashMap<>();
          this.unusableDelegate =
              (SetMultimap<K, V>)
                  newProxy(
                      SetMultimap.class,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Sep 24 22:52:18 GMT 2025
    - 28.6K bytes
    - Click Count (0)
Back to Top