Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 148 for interrupt (0.13 sec)

  1. guava-testlib/src/com/google/common/testing/TestLogHandler.java

    import java.util.Collections;
    import java.util.List;
    import java.util.logging.Handler;
    import java.util.logging.LogRecord;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Tests may use this to intercept messages that are logged by the code under test. Example:
     *
     * <pre>
     *   TestLogHandler handler;
     *
     *   protected void setUp() throws Exception {
     *     super.setUp();
     *     handler = new TestLogHandler();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 21 20:53:25 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseResponseInterceptor.kt

    import okio.ForwardingSource
    import okio.buffer
    
    /** Rewrites the response body returned from the server to be all uppercase.  */
    class UppercaseResponseInterceptor : Interceptor {
      @Throws(IOException::class)
      override fun intercept(chain: Chain): Response {
        return uppercaseResponse(chain.proceed(chain.request()))
      }
    
      private fun uppercaseResponse(response: Response): Response {
        val uppercaseBody: ResponseBody =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseRequestInterceptor.kt

    import okio.Sink
    import okio.buffer
    
    /** Rewrites the request body sent to the server to be all uppercase.  */
    class UppercaseRequestInterceptor : Interceptor {
      @Throws(IOException::class)
      override fun intercept(chain: Chain): Response {
        return chain.proceed(uppercaseRequest(chain.request()))
      }
    
      /** Returns a request that transforms `request` to be all uppercase.  */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/LoadingCache.java

       *     ExecutionException} is thrown <a
       *     href="https://github.com/google/guava/wiki/CachesExplained#interruption">even if
       *     computation was interrupted by an {@code InterruptedException}</a>.)
       * @throws UncheckedExecutionException if an unchecked exception was thrown while loading the
       *     value
       * @throws ExecutionError if an error was thrown while loading the value
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Aug 06 17:12:03 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  5. okhttp-logging-interceptor/api/logging-interceptor.api

    	public synthetic fun <init> (Lokhttp3/logging/HttpLoggingInterceptor$Logger;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
    	public final fun getLevel ()Lokhttp3/logging/HttpLoggingInterceptor$Level;
    	public fun intercept (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
    	public final fun level (Lokhttp3/logging/HttpLoggingInterceptor$Level;)V
    	public final fun redactHeader (Ljava/lang/String;)V
    	public final fun redactQueryParams ([Ljava/lang/String;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 09:14:38 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       * the source future indefinitely, so if the source future never completes, the adapter will never
       * complete either.
       *
       * <p>If the delegate future is interrupted or throws an unexpected unchecked exception, the
       * listeners will not be invoked.
       */
      private static class ListenableFutureAdapter<V extends @Nullable Object>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

                        logger.debug("Interrupted.", e);
                    }
                }
            }
    
            public void awaitTermination(final long mills) {
                try {
                    join(mills);
                } catch (final InterruptedException e) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Interrupted.", e);
                    }
                }
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12K bytes
    - Viewed (0)
  8. samples/guide/src/main/java/okhttp3/recipes/RequestBodyCompression.java

      }
    
      /** This interceptor compresses the HTTP request body. Many webservers can't handle this! */
      static class GzipRequestInterceptor implements Interceptor {
        @Override public Response intercept(Chain chain) throws IOException {
          Request originalRequest = chain.request();
          if (originalRequest.body() == null || originalRequest.header("Content-Encoding") != null) {
            return chain.proceed(originalRequest);
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat May 25 18:02:55 UTC 2019
    - 3.8K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

        val next = copy(index = index + 1, request = request)
        val interceptor = interceptors[index]
    
        @Suppress("USELESS_ELVIS")
        val response =
          interceptor.intercept(next) ?: throw NullPointerException(
            "interceptor $interceptor returned null",
          )
    
        if (exchange != null) {
          check(index + 1 >= interceptors.size || next.calls == 1) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

    /** This is the last interceptor in the chain. It makes a network call to the server. */
    class CallServerInterceptor(private val forWebSocket: Boolean) : Interceptor {
      @Throws(IOException::class)
      override fun intercept(chain: Interceptor.Chain): Response {
        val realChain = chain as RealInterceptorChain
        val exchange = realChain.exchange!!
        val request = realChain.request
        val requestBody = request.body
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.3K bytes
    - Viewed (0)
Back to top