Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 607 for direct (0.05 seconds)

  1. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

          interruptenator.shutdown();
          Thread.interrupted();
        }
      }
    
      /**
       * awaitFullGc() is not quite as reliable a way to ensure calling of a specific finalize method as
       * the more direct await* methods, but should be reliable enough in practice to avoid flakiness of
       * this test. (And if it isn't, we'd like to know about it first!)
       */
      public void testAwaitFullGc() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 08 17:02:07 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt

        val mutableInetSocketAddresses = mutableListOf<InetSocketAddress>()
        inetSocketAddresses = mutableInetSocketAddresses
    
        val socketHost: String
        val socketPort: Int
        if (proxy.type() == Proxy.Type.DIRECT || proxy.type() == Proxy.Type.SOCKS) {
          socketHost = address.url.host
          socketPort = address.url.port
        } else {
          val proxyAddress = proxy.address()
          require(proxyAddress is InetSocketAddress) {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 7.3K bytes
    - Click Count (2)
  3. guava-tests/test/com/google/common/io/FileBackedOutputStreamTest.java

       * threshold"). (We then write some more afterward.) This differs from the existing
       * testThreshold() which writes exactly enough bytes to fill the buffer, then immediately writes
       * more bytes.
       *
       * <p>Note: Direct testing of the {@link IOException} scenario during write/flush is challenging
       * without mocking. This test verifies that normal operation with threshold crossing still works
       * correctly with the fix in place.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Oct 30 16:30:29 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  4. cmd/metacache-stream.go

    	}
    	// We have checked if prefix matches, so we can do direct compare.
    	return b.First > prefix
    }
    
    // endedPrefix returns true if the given prefix ends within the block.
    func (b metacacheBlock) endedPrefix(prefix string) bool {
    	if prefix == "" || strings.HasPrefix(b.Last, prefix) {
    		return false
    	}
    
    	// We have checked if prefix matches, so we can do direct compare.
    	return b.Last > prefix
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/escape/ArrayBasedUnicodeEscaper.java

              || c > safeMaxChar
              || c < safeMinChar) {
            break;
          }
          index++;
        }
        return index;
      }
    
      /**
       * Escapes a code point that has no direct explicit value in the replacement array and lies
       * outside the stated safe range. Subclasses should override this method to provide generalized
       * escaping for code points if required.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 15:45:16 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

     * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException} or an exception
     * thrown by {@linkplain MoreExecutors#directExecutor direct execution}) will be caught and logged.
     *
     * @author Nishant Thakkar
     * @author Sven Mawson
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class ExecutionList {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.9K bytes
    - Click Count (0)
  7. guava/src/com/google/common/eventbus/Dispatcher.java

       * dispatching an event, guaranteeing that all events posted on a single thread are dispatched to
       * all subscribers in the order they are posted.
       *
       * <p>When all subscribers are dispatched to using a <i>direct</i> executor (which dispatches on
       * the same thread that posts the event), this yields a breadth-first dispatch order on each
       * thread. That is, all subscribers to a single event A will be called before any subscribers to
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java

            return chars;
          }
        }
        if (c >= safeMin && c <= safeMax) {
          return null;
        }
        return escapeUnsafe(c);
      }
    
      /**
       * Escapes a {@code char} value that has no direct explicit value in the replacement array and
       * lies outside the stated safe range. Subclasses should override this method to provide
       * generalized escaping for characters.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.2K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/collect/Tables.java

       * users with "read-only" access to internal tables. Query operations on the returned table "read
       * through" to the specified table, and attempts to modify the returned table, whether direct or
       * via its collection views, result in an {@code UnsupportedOperationException}.
       *
       * <p>The returned table will be serializable if the specified table is serializable.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

            throw e;
            // The execution of a task has ended abnormally.
            // We could have tasks left in the queue, so should perhaps try to restart a worker,
            // but then the Error will get delayed if we are using a direct (same thread) executor.
          }
        }
    
        /**
         * Continues executing tasks from {@link #queue} until it is empty.
         *
         * <p>The thread's interrupt bit is cleared before execution of each task.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
Back to Top