Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 187 for DIRECT (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Address.kt

      protocols: List<Protocol>,
      connectionSpecs: List<ConnectionSpec>,
      /**
       * Returns this address's proxy selector. Only used if the proxy is null. If none of this
       * selector's proxies are reachable, a direct connection will be attempted.
       */
      @get:JvmName("proxySelector") val proxySelector: ProxySelector,
    ) {
      /**
       * Returns a URL with the hostname and port of the origin server. The path, query, and fragment of
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/MutableClassToInstanceMap.java

      }
    
      /**
       * Returns a new {@code MutableClassToInstanceMap} instance backed by a given empty {@code
       * backingMap}. The caller surrenders control of the backing map, and thus should not allow any
       * direct references to it to remain accessible.
       */
      public static <B extends @Nullable Object> MutableClassToInstanceMap<B> create(
          Map<Class<? extends @NonNull B>, B> backingMap) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Aug 11 22:10:29 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  3. 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)
  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/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)
  9. 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)
  10. 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