Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1061 - 1070 of 2,888 for throwIf (0.16 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-testlib/src/com/google/common/collect/testing/testers/MapPutTester.java

      private Entry<K, V> nullKeyEntry;
      private Entry<K, V> nullValueEntry;
      private Entry<K, V> nullKeyValueEntry;
      private Entry<K, V> presentKeyNullValueEntry;
    
      @Override
      public void setUp() throws Exception {
        super.setUp();
        nullKeyEntry = entry(null, v3());
        nullValueEntry = entry(k3(), null);
        nullKeyValueEntry = entry(null, null);
        presentKeyNullValueEntry = entry(k0(), null);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/fess/app/web/admin/searchlist/AdminSearchlistActionTest.java

    import org.lastaflute.web.validation.VaMessenger;
    
    public class AdminSearchlistActionTest extends UnitFessTestCase {
    
        @Override
        protected void setUp(TestInfo testInfo) throws Exception {
            super.setUp(testInfo);
            ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
                private static final long serialVersionUID = 1L;
    
                @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:38:39 GMT 2026
    - 34.4K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

        call1.enqueue(
          object : Callback {
            @Throws(IOException::class)
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              try {
                // Wait until request2 acquires the connection before we destroy it violently.
                latch3.await()
              } catch (e: InterruptedException) {
                throw AssertionError(e)
              }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jun 19 11:44:16 GMT 2025
    - 19.1K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt

         *
         * It is an error to call this multiple times on the same instance.
         *
         * @throws IllegalStateException if this request doesn't have a request body, or if it already
         *     has a 'Content-Encoding' header.
         */
        fun gzip() =
          apply {
            val identityBody =
              body
                ?: throw IllegalStateException("cannot gzip a request that has no body")
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Oct 30 13:46:58 GMT 2025
    - 14.7K bytes
    - Click Count (1)
  5. android/guava-tests/test/com/google/common/cache/CacheBuilderGwtTest.java

        fakeTicker = new FakeTicker();
      }
    
      @Test
      public void loader() throws ExecutionException {
        Cache<Integer, Integer> cache = CacheBuilder.newBuilder().build();
    
        Callable<Integer> loader =
            new Callable<Integer>() {
              private int i = 0;
    
              @Override
              public Integer call() throws Exception {
                return ++i;
              }
            };
    
        cache.put(0, 10);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 15K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MediaType.kt

        /**
         * Returns a media type for this string.
         *
         * @throws IllegalArgumentException if this is not a well-formed media type.
         */
        @JvmStatic
        @JvmName("get")
        fun String.toMediaType(): MediaType {
          val typeSubtype =
            TYPE_SUBTYPE.matchAt(this, 0)
              ?: throw IllegalArgumentException("No subtype found for: \"$this\"")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.9K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb2/create/Smb2CloseResponse.java

         */
        @Override
        protected int readBytesWireFormat(final byte[] buffer, int bufferIndex) throws SMBProtocolDecodingException {
            final int start = bufferIndex;
            final int structureSize = SMBUtil.readInt2(buffer, bufferIndex);
            if (structureSize != 60) {
                throw new SMBProtocolDecodingException("Expected structureSize = 60");
            }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/base/CharMatcherTest.java

        doTestNull(forPredicate(Predicates.equalTo('c')));
      }
    
      private void doTestEmpty(CharMatcher matcher) throws Exception {
        reallyTestEmpty(matcher);
        reallyTestEmpty(matcher.negate());
        reallyTestEmpty(matcher.precomputed());
      }
    
      private void reallyTestEmpty(CharMatcher matcher) throws Exception {
        assertEquals(-1, matcher.indexIn(""));
        assertEquals(-1, matcher.indexIn("", 0));
        try {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 32.4K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/indexer/DocBoostMatcherTest.java

    import groovy.lang.Binding;
    import groovy.lang.GroovyClassLoader;
    import groovy.lang.GroovyShell;
    
    public class DocBoostMatcherTest extends UnitFessTestCase {
    
        @Override
        protected void setUp(TestInfo testInfo) throws Exception {
            super.setUp(testInfo);
            ScriptEngineFactory scriptEngineFactory = new ScriptEngineFactory();
            ComponentUtil.register(scriptEngineFactory, "scriptEngineFactory");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Mar 15 06:03:38 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

       * is running when that time is reached, that task is allowed to complete before this task is
       * started. Similarly the task will be delayed if the host lacks compute resources.
       *
       * @throws RejectedExecutionException if the queue is shut down and the task is not cancelable.
       */
      fun schedule(
        task: Task,
        delayNanos: Long = 0L,
      ) {
        taskRunner.withLock {
          if (shutdown) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 7.3K bytes
    - Click Count (0)
Back to Top