Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 148 for interrupt (0.1 sec)

  1. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       */
      @CanIgnoreReturnValue
      @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
      public boolean cancel(boolean mayInterruptIfRunning) {
        logger.get().log(FINER, "cancelling {0}", this);
        boolean cancelled = future.cancel(mayInterruptIfRunning);
        if (cancelled) {
          close();
        }
        return cancelled;
      }
    
      private void close() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  2. guava/src/com/google/common/cache/LocalCache.java

          } catch (Throwable t) {
            ListenableFuture<V> result = setException(t) ? futureValue : fullyFailedFuture(t);
            if (t instanceof InterruptedException) {
              Thread.currentThread().interrupt();
            }
            return result;
          }
        }
    
        @CheckForNull
        public V compute(
            K key, BiFunction<? super K, ? super @Nullable V, ? extends @Nullable V> function) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbFile.java

                }
                finally {
                    w.write(null, -1, null);
                    w.interrupt();
                    try {
                        w.join();
                    }
                    catch ( InterruptedException e ) {
                        log.warn("Interrupted while joining copy thread", e);
                    }
                }
            }
            catch ( CIFSException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu May 23 01:50:13 UTC 2024
    - 82.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * the target, and throw a {@link TimeoutException} to the caller.
       *
       * <p>The difference with {@link #callWithTimeout(Callable, long, TimeUnit)} is that this method
       * will ignore interrupts on the current thread.
       *
       * @param callable the Callable to execute
       * @param timeoutDuration with timeoutUnit, the maximum length of time to wait
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  5. src/main/webapp/js/admin/popper.min.js.map

    '[x-arrow]',\n  },\n\n  /**\n   * Modifier used to flip the popper's placement when it starts to overlap its\n   * reference element.\n   *\n   * Requires the `preventOverflow` modifier before it in order to work.\n   *\n   * **NOTE:** this modifier will interrupt the current update cycle and will\n   * restart it if it detects the need to flip the placement.\n   * @memberof modifiers\n   * @inner\n   */\n  flip: {\n    /** @prop {number} order=600 - Index used to define the order of execution */\n    order:...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 120.9K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

    the Hatter and the March Hare went `Sh! sh!' and the Dormouse
    sulkily remarked, `If you can't be civil, you'd better finish the
    story for yourself.'
    
      `No, please go on!' Alice said very humbly; `I won't interrupt
    again.  I dare say there may be ONE.'
    
      `One, indeed!' said the Dormouse indignantly.  However, he
    consented to go on.  `And so these three little sisters--they
    were learning to draw, you know--'
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 29 21:35:03 UTC 2012
    - 145.2K bytes
    - Viewed (0)
  7. okhttp-brotli/api/okhttp-brotli.api

    public final class okhttp3/brotli/BrotliInterceptor : okhttp3/Interceptor {
    	public static final field INSTANCE Lokhttp3/brotli/BrotliInterceptor;
    	public fun intercept (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Feb 26 19:17:33 UTC 2022
    - 220 bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectInterceptor.kt

     * be used for the returned response, or to validate a cached response with a conditional GET.
     */
    object ConnectInterceptor : Interceptor {
      @Throws(IOException::class)
      override fun intercept(chain: Interceptor.Chain): Response {
        val realChain = chain as RealInterceptorChain
        val exchange = realChain.call.initExchange(realChain)
        val connectedChain = realChain.copy(exchange = exchange)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  9. docs/features/interceptors.md

    ```java
    class LoggingInterceptor implements Interceptor {
      @Override public Response intercept(Interceptor.Chain chain) throws IOException {
        Request request = chain.request();
    
        long t1 = System.nanoTime();
        logger.info(String.format("Sending request %s on %s%n%s",
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 8.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/Interceptor.kt

     *    libraries may customize this behavior.)
     *
     * A good way to signal a failure is with a synthetic HTTP response:
     *
     * ```kotlin
     *   @Throws(IOException::class)
     *   override fun intercept(chain: Interceptor.Chain): Response {
     *     if (myConfig.isInvalid()) {
     *       return Response.Builder()
     *           .request(chain.request())
     *           .protocol(Protocol.HTTP_1_1)
     *           .code(400)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
Back to top