Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 545 for direkt (0.05 seconds)

  1. 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)
  2. 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)
  3. src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java

            });
        }
    
        /**
         * Generates a hashed ID from the provided URL ID string.
         * Encodes special characters using URL encoding or Base64 encoding as needed,
         * then applies a message digest algorithm to create a unique hash.
         *
         * @param urlId the URL ID string to generate a hash for
         * @return a hashed ID string generated from the input URL ID
         */
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 15.2K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. src/main/java/org/codelibs/curl/Curl.java

         */
        public static final File tmpDir = new File(System.getProperty("java.io.tmpdir"));
    
        /**
         * Protected constructor to prevent direct instantiation but allow inheritance.
         */
        protected Curl() {
            // nothing
        }
    
        /**
         * Creates a new CurlRequest with the HTTP GET method for the specified URL.
         *
    Created: Sat Dec 20 09:13:53 GMT 2025
    - Last Modified: Thu Nov 20 13:34:13 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  8. 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)
  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