Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 584 for Calls (0.02 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt

    ) : AbstractExecutorService() {
      private var shutdown: Boolean = false
      private val calls = mutableListOf<RealCall.AsyncCall>()
    
      override fun execute(command: Runnable) {
        if (shutdown) throw RejectedExecutionException()
        calls.add(command as RealCall.AsyncCall)
      }
    
      fun assertJobs(vararg expectedUrls: String) {
        val actualUrls = calls.map { it.request.url.toString() }
        assertThat(actualUrls).containsExactly(*expectedUrls)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/base/SuppliersTest.java

     */
    @NullMarked
    @GwtCompatible
    public class SuppliersTest extends TestCase {
    
      static class CountingSupplier implements Supplier<Integer> {
        int calls = 0;
    
        @Override
        public Integer get() {
          calls++;
          return calls * 10;
        }
    
        @Override
        public String toString() {
          return "CountingSupplier";
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  3. cmd/lock-rest-client.go

    	}
    	return ok, err
    }
    
    // RLock calls read lock REST API.
    func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRLock, &args)
    }
    
    // Lock calls lock REST API.
    func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCLock, &args)
    }
    
    // RUnlock calls read unlock REST API.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. mkdocs.yml

          alternate_style: true
      - tables
    
    plugins:
      - search
      - redirects:
          redirect_maps:
            # Redirect all feature pages to features/*
            'caching.md': 'features/caching.md'
            'calls.md': 'features/calls.md'
            'connections.md': 'features/connections.md'
            'events.md': 'features/events.md'
            'https.md': 'features/events.md'
            'interceptors.md': 'features/interceptors.md'
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Nov 21 07:19:31 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        return capacityWithoutIt >= addressState.policy.minimumConcurrentCalls
      }
    
      /**
       * 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.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  6. 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() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/features/MapFeature.java

      /**
       * The map does not throw {@code NullPointerException} on calls such as {@code containsKey(null)},
       * {@code get(null)}, {@code keySet().contains(null)} or {@code remove(null)}.
       */
      ALLOWS_NULL_KEY_QUERIES,
      ALLOWS_NULL_KEYS(ALLOWS_NULL_KEY_QUERIES),
      /**
       * The map does not throw {@code NullPointerException} on calls such as {@code
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jan 30 16:59:10 UTC 2025
    - 3K bytes
    - Viewed (0)
  8. android/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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/StaticJAASConfigurationTest.java

    /**
     * Tests for StaticJAASConfiguration.
     *
     * Coverage goals:
     * - Happy path with default and custom options.
     * - Null/empty/ignored name parameter handling.
     * - Null options edge case.
     * - Repeated calls equivalence and instance separation.
     * - Interaction check that passed options are not mutated.
     */
    @ExtendWith(MockitoExtension.class)
    class StaticJAASConfigurationTest {
    
        // Constants used in assertions
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7K bytes
    - Viewed (0)
  10. 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. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 8.7K bytes
    - Viewed (0)
Back to top