Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 211 for intercept (2.98 sec)

  1. 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());
      }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Mar 07 18:34:03 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

         * 3. We expect the client's get() to throw an InterruptedException.
         * 4. We expect the client thread's interrupt state to be false.
         * 5. The client thread again makes a blocking call to get().
         * 6. Now the result becomes available.
         * 7. We expect get() to return this result.
         * 8. We expect the test thread's interrupt state to be false.
         */
        InterruptionUtil.requestInterruptIn(200, TimeUnit.MILLISECONDS);
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 9.1K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

          Thread.currentThread().interrupt()
        }
      }
    
      private fun cancelLater(
        call: Call,
        delayMillis: Int,
      ): CountDownLatch {
        val latch = CountDownLatch(1)
        Thread {
          sleep(delayMillis)
          if (cancelMode == CANCEL) {
            call.cancel()
          } else {
            threadToCancel!!.interrupt()
          }
          latch.countDown()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 9.9K bytes
    - Viewed (0)
  4. 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) })
    
        /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:21:33 GMT 2024
    - 52K bytes
    - Viewed (0)
  5. okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    genting
    
    // george : 2015-07-31 Wal-Mart Stores, Inc.
    george
    
    // ggee : 2014-01-09 GMO Internet, Inc.
    ggee
    
    // gift : 2013-10-17 DotGift, LLC
    gift
    
    // gifts : 2014-07-03 Binky Moon, LLC
    gifts
    
    // gives : 2014-03-06 Public Interest Registry
    gives
    
    // giving : 2014-11-13 Public Interest Registry
    giving
    
    // glass : 2013-11-07 Binky Moon, LLC
    glass
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 240.3K bytes
    - Viewed (3)
  6. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        // We need to wait for the runner to exit.  It used to be that the runner would get stuck in the
        // busy loop when interrupt threw.
        runner.join(TimeUnit.SECONDS.toMillis(10));
      }
    
      static final class BrokenChannel extends AbstractInterruptibleChannel {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K 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())
      }
    }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Apr 14 14:24:05 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        // We need to wait for the runner to exit.  It used to be that the runner would get stuck in the
        // busy loop when interrupt threw.
        runner.join(TimeUnit.SECONDS.toMillis(10));
      }
    
      static final class BrokenChannel extends AbstractInterruptibleChannel {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                }
                task = queue.poll();
                if (task == null) {
                  workerRunningState = IDLE;
                  return;
                }
              }
              // Remove the interrupt bit before each task. The interrupt is for the "current task" when
              // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
              // by a previous one in the queue being interrupted.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  10. 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)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 13.2K bytes
    - Viewed (0)
Back to top