Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 55 for intercepted (0.12 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

          client
            .newBuilder()
            .addNetworkInterceptor(
              Interceptor { chain: Interceptor.Chain ->
                ifNoneMatch.compareAndSet(null, chain.request().header("If-None-Match"))
                chain.proceed(chain.request())
              },
            ).build()
    
        // Confirm the value is cached and intercepted.
        assertThat(get(url).body.string()).isEqualTo("A")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 113.6K bytes
    - Viewed (0)
  2. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

     *
     * The format of the logs created by this class should not be considered stable and may
     * change slightly between releases. If you need a stable logging format, use your own interceptor.
     */
    class HttpLoggingInterceptor
      @JvmOverloads
      constructor(
        private val logger: Logger = Logger.DEFAULT,
      ) : Interceptor {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Aug 21 14:27:04 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  3. okhttp/api/jvm/okhttp.api

    	public final fun parse (Ljava/lang/String;)Lokhttp3/HttpUrl;
    }
    
    public abstract interface class okhttp3/Interceptor {
    	public static final field Companion Lokhttp3/Interceptor$Companion;
    	public abstract fun intercept (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
    }
    
    public abstract interface class okhttp3/Interceptor$Chain {
    	public abstract fun call ()Lokhttp3/Call;
    	public abstract fun connectTimeoutMillis ()I
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      public static void awaitUninterruptibly(CountDownLatch latch) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
              latch.await();
              return;
            } catch (InterruptedException e) {
              interrupted = true;
            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  5. okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

      private var extraNetworkInterceptor: Interceptor? = null
    
      private fun setLevel(level: Level) {
        networkInterceptor.setLevel(level)
        applicationInterceptor.setLevel(level)
      }
    
      @BeforeEach
      fun setUp() {
        client =
          OkHttpClient
            .Builder()
            .addNetworkInterceptor(
              Interceptor { chain ->
                when {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Aug 21 14:27:04 UTC 2025
    - 37.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        /*
         * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.
         * Wait for the interrupting thread to set DONE. (See interruptTask().) We want to wait so that
         * the interrupting thread doesn't interrupt the _next_ thing to run on this thread.
         *
         * Note: We don't reset the interrupted bit, just wait for it to be set. If this is a thread
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  7. okhttp/api/android/okhttp.api

    	public final fun parse (Ljava/lang/String;)Lokhttp3/HttpUrl;
    }
    
    public abstract interface class okhttp3/Interceptor {
    	public static final field Companion Lokhttp3/Interceptor$Companion;
    	public abstract fun intercept (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
    }
    
    public abstract interface class okhttp3/Interceptor$Chain {
    	public abstract fun call ()Lokhttp3/Call;
    	public abstract fun connectTimeoutMillis ()I
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

              NANOSECONDS.timedJoin(thread, remainingNanos);
              return;
            } catch (InterruptedException e) {
              interrupted = true;
              remainingNanos = end - System.nanoTime();
            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
      }
    
      private InterruptionUtil() {}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

              NANOSECONDS.timedJoin(thread, remainingNanos);
              return;
            } catch (InterruptedException e) {
              interrupted = true;
              remainingNanos = end - System.nanoTime();
            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
      }
    
      private InterruptionUtil() {}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Queues.java

                } catch (InterruptedException ex) {
                  interrupted = true; // note interruption and retry
                }
              }
              if (e == null) {
                break; // we already waited enough, and there are no more elements in sight
              }
              buffer.add(e);
              added++;
            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.3K bytes
    - Viewed (0)
Back to top