Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 238 for Calls (0.04 seconds)

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

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

          return executorServiceOrNull!!
        }
    
      /** Ready async calls in the order they'll be run. */
      private val readyAsyncCalls = ArrayDeque<AsyncCall>()
    
      /** Running asynchronous calls. Includes canceled calls that haven't finished yet. */
      private val runningAsyncCalls = ArrayDeque<AsyncCall>()
    
      /** Running synchronous calls. Includes canceled calls that haven't finished yet. */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 14:16:22 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

          }
    
          else -> {
            // No connections, idle or in use.
            return -1
          }
        }
      }
    
      /**
       * Prunes any leaked calls and then returns the number of remaining live calls on [connection].
       * Calls are leaked if the connection is tracking them but the application code has abandoned
       * them. Leak detection is imprecise and relies on garbage collection.
       */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/SmbNegotiationTest.java

            // Verify getRequest returns the exact same instance
            SmbNegotiationRequest request = negotiation.getRequest();
            assertSame(mockRequest, request);
    
            // Verify multiple calls return the same instance
            assertSame(request, negotiation.getRequest());
        }
    
        @Test
        @DisplayName("getResponse should return the same response instance")
        void testGetResponse() {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

        // Cancel some calls. That doesn't impact running or queued.
        a2.cancel()
        a3.cancel()
        assertThat(dispatcher.runningCalls())
          .containsExactlyInAnyOrder(a1, a2)
        assertThat(dispatcher.queuedCalls()).isEmpty()
    
        // Let the calls finish.
        waiting.countDown()
        t1.join()
        t2.join()
    
        // Now we should have 0 running calls and 0 queued calls.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  5. src/test/java/jcifs/context/BaseContextTest.java

            // Then
            assertNotNull(transportPool, "Transport pool should not be null");
            assertSame(transportPool, context.getTransportPool(), "Should return same instance on multiple calls");
        }
    
        @Test
        @DisplayName("getConfig should return the provided configuration")
        void testGetConfig() {
            // When
            Configuration config = context.getConfig();
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     * Tasks execute with the same happens-before order that the function calls to {@link #submit} and
     * {@link #submitAsync} that submitted those tasks had.
     *
     * <p>This class has limited support for cancellation and other "early completions":
     *
     * <ul>
     *   <li>While calls to {@code submit} and {@code submitAsync} return a {@code Future} that can be
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  7. guava/src/com/google/common/base/Suppliers.java

       * exception.
       *
       * <p>When the underlying delegate throws an exception then this memoizing supplier will keep
       * delegating calls until it returns valid data.
       *
       * @param duration the length of time after a value is created that it should stop being returned
       *     by subsequent {@code get()} calls
       * @param unit the unit that {@code duration} is expressed in
       * @throws IllegalArgumentException if {@code duration} is not positive
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  8. CHANGELOG.md

        ```
    
     *  New: Support the `QUERY` HTTP method. You will need to set the `Request.cacheUrlOverride`
        property to cache calls made with this method. The `RequestBody.sha256()` may be helpful here;
        use it to compose a cache URL from the query body.
    
     *  New: Publish events when calls must wait to execute. `EventListener.dispatcherQueueStart()`
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 05 16:02:59 GMT 2025
    - 36.2K bytes
    - Click Count (2)
  9. android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java

      }
    
      @IgnoreJRERequirement // helper for toImmutableSortedMultiset
      /*
       * If we make these calls inline inside toImmutableSortedMultiset, we get an Animal Sniffer error,
       * despite the @IgnoreJRERequirement annotation there. My assumption is that, because javac
       * generates a synthetic method for the body of the lambda, the actual method calls that Animal
       * Sniffer is flagging don't appear inside toImmutableSortedMultiset but rather inside that
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 35.2K bytes
    - Click Count (0)
  10. src/test/java/jcifs/internal/smb2/RequestWithFileIdTest.java

            // When
            mockRequest.setFileId(testFileId);
    
            // Then
            verify(mockRequest, times(1)).setFileId(testFileId);
        }
    
        @Test
        @DisplayName("Should handle multiple setFileId calls")
        void testMultipleSetFileIdCalls() {
            // Given
            RequestWithFileId request = new Smb2CloseRequest(mockConfig, emptyFileId);
            byte[] firstFileId = new byte[16];
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.9K bytes
    - Click Count (0)
Back to Top