Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1011 - 1020 of 1,335 for afterFn (0.05 sec)

  1. android/guava/src/com/google/common/io/Closer.java

       * <i>first</i> exception to be thrown from an attempt to close a closeable will be thrown and any
       * additional exceptions that are thrown after that will be suppressed.
       */
      @Override
      public void close() throws IOException {
        Throwable throwable = thrown;
    
        // close closeables in LIFO order
        while (!stack.isEmpty()) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/GcFinalization.java

       * from GC, as with {@link #awaitClear}. Because there are no guarantees for the order of GC
       * finalization processing, there may still be some unfinished work for the GC to do after this
       * method returns.
       *
       * <p>This method does not create any memory pressure as would be required to cause soft
       * references to be processed.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

       * from GC, as with {@link #awaitClear}. Because there are no guarantees for the order of GC
       * finalization processing, there may still be some unfinished work for the GC to do after this
       * method returns.
       *
       * <p>This method does not create any memory pressure as would be required to cause soft
       * references to be processed.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        // Give the server time to enact the socket policy if it's one that could happen after the
        // client has received the response.
        Thread.sleep(500)
        val response2 = getResponse(newRequest("/b"))
        response1.body
          .source()
          .timeout()
          .timeout(100, TimeUnit.MILLISECONDS)
        assertContent("This comes after a busted connection", response2)
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    	return &HTTPRangeSpec{Start: start, End: end}
    }
    
    // Returns the compressed offset which should be skipped.
    // If encrypted offsets are adjusted for encrypted block headers/trailers.
    // Since de-compression is after decryption encryption overhead is only added to compressedOffset.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

     * atomic: a read observes the full set of values as they were before or after the commit, but never
     * a mix of values.
     *
     * Clients call [get] to read a snapshot of an entry. The read will observe the value at the time
     * that [get] was called. Updates and removals after the call do not impact ongoing reads.
     *
     * This class is tolerant of some I/O errors. If files are missing from the filesystem, the
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  7. cmd/common-main.go

    		return
    	}
    
    	_, lrTime, err := getLatestReleaseTime(u, 2*time.Second, mode)
    	if err != nil {
    		return
    	}
    
    	var older time.Duration
    	var downloadURL string
    	if lrTime.After(currentReleaseTime) {
    		older = lrTime.Sub(currentReleaseTime)
    		downloadURL = getDownloadURL(releaseTimeToReleaseTag(lrTime))
    	}
    
    	updateMsg := prepareUpdateMessage(downloadURL, older)
    	if updateMsg == "" {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  8. src/test/java/jcifs/internal/smb2/nego/NegotiateContextResponseTest.java

                assertEquals(0, buffer[13]);
                assertEquals((byte) 0xFF, buffer[9]); // Should not modify before offset
                assertEquals((byte) 0xFF, buffer[14]); // Should not modify after encoded data
            }
    
            @Test
            @DisplayName("Should handle offset in decode")
            void testDecodeWithOffset() throws SMBProtocolDecodingException {
                // Arrange
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

      }
    
      /**
       * Returns true if this connection's route has the same address as any of [candidates]. This
       * requires us to have a DNS address for both hosts, which only happens after route planning. We
       * can't coalesce connections that use a proxy, since proxies don't tell us the origin server's IP
       * address.
       */
      private fun routeMatchesAny(candidates: List<Route>): Boolean =
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SmbFileTest.java

                when(mockTreeHandle.isSMB2()).thenReturn(false);
    
                // The delete method for directories uses SmbComDelete with the directory flag
                // After checking SMB code, directories are deleted using SmbComDelete with ATTR_DIRECTORY
                when(mockTreeHandle.send(any(SmbComDelete.class), any(SmbComBlankResponse.class))).thenReturn(mock(SmbComBlankResponse.class));
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 20.8K bytes
    - Viewed (0)
Back to top