Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 230 for intercept (0.13 sec)

  1. okhttp/src/test/java/okhttp3/OkHttpClientTest.kt

        }
      }
    
      @Test fun clonedInterceptorsListsAreIndependent() {
        val interceptor =
          Interceptor { chain: Interceptor.Chain ->
            chain.proceed(chain.request())
          }
        val original = clientTestRule.newClient()
        original.newBuilder()
          .addInterceptor(interceptor)
          .addNetworkInterceptor(interceptor)
          .build()
        assertThat(original.interceptors.size).isEqualTo(0)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/core/v1/generated.proto

      // kubelet.  If the kubelet is configured to verify the apiserver's TLS credentials, it does not mean the
      // connection to the real kubelet is vulnerable to a man in the middle attack (e.g. an attacker could not intercept
      // the actual log data coming from the real kubelet).
      // +optional
      optional bool insecureSkipTLSVerifyBackend = 9;
    }
    
    // PodOS defines the OS parameters of a pod.
    message PodOS {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 255.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            }
          } else {
            Thread.yield();
          }
          state = get();
        }
        if (restoreInterruptedBit) {
          currentThread.interrupt();
        }
        /*
         * TODO(cpovirk): Clear interrupt status here? We currently don't, which means that an interrupt
         * before, during, or after runInterruptibly() (unless it produced an InterruptedException
         * caught above) can linger and affect listeners.
         */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

              latch.await();
              return;
            } catch (InterruptedException e) {
              interrupted = true;
            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
      }
    
      /**
       * Invokes {@code latch.}{@link CountDownLatch#await(long, TimeUnit) await(timeout, unit)}
       * uninterruptibly.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/GeneralRangeTest.java

            range.intersect(GeneralRange.range(ORDERING, 1, OPEN, 3, OPEN)));
      }
    
      public void testIntersectNonOverlappingRange() {
        GeneralRange<Integer> range = GeneralRange.range(ORDERING, 2, OPEN, 4, CLOSED);
        assertTrue(range.intersect(GeneralRange.range(ORDERING, 5, CLOSED, 6, CLOSED)).isEmpty());
        assertTrue(range.intersect(GeneralRange.range(ORDERING, 1, OPEN, 2, OPEN)).isEmpty());
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

     *
     * @author Kevin Bourrillion
     * @author Chris Povirk
     */
    final class InterruptionUtil {
      private static final Logger logger = Logger.getLogger(InterruptionUtil.class.getName());
    
      /** Runnable which will interrupt the target thread repeatedly when run. */
      private static final class Interruptenator implements Runnable {
        private final long everyMillis;
        private final Thread interruptee;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
  7. settings.gradle.kts

    include(":samples:simple-client")
    include(":samples:slack")
    include(":samples:static-server")
    include(":samples:tlssurvey")
    include(":samples:unixdomainsockets")
    include(":container-tests")
    
    project(":okhttp-logging-interceptor").name = "logging-interceptor"
    
    val androidHome = System.getenv("ANDROID_HOME")
    val localProperties = Properties().apply {
      val file = File("local.properties")
      if (file.exists()) {
        load(file.inputStream())
      }
    }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Apr 14 14:24:05 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. samples/guide/src/main/java/okhttp3/recipes/RewriteResponseCacheControl.java

    import java.io.File;
    import java.io.IOException;
    import okhttp3.Cache;
    import okhttp3.Interceptor;
    import okhttp3.OkHttpClient;
    import okhttp3.Request;
    import okhttp3.Response;
    
    public final class RewriteResponseCacheControl {
      /** Dangerous interceptor that rewrites the server's cache-control header. */
      private static final Interceptor REWRITE_CACHE_CONTROL_INTERCEPTOR = chain -> {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 2.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

         */
        fun interceptors(): MutableList<Interceptor> = interceptors
    
        fun addInterceptor(interceptor: Interceptor) =
          apply {
            interceptors += interceptor
          }
    
        @JvmName("-addInterceptor") // Prefix with '-' to prevent ambiguous overloads from Java.
        inline fun addInterceptor(crossinline block: (chain: Interceptor.Chain) -> Response) =
          addInterceptor(Interceptor { chain -> block(chain) })
    
        /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            }
          } else {
            Thread.yield();
          }
          state = get();
        }
        if (restoreInterruptedBit) {
          currentThread.interrupt();
        }
        /*
         * TODO(cpovirk): Clear interrupt status here? We currently don't, which means that an interrupt
         * before, during, or after runInterruptibly() (unless it produced an InterruptedException
         * caught above) can linger and affect listeners.
         */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top