Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1421 - 1430 of 1,882 for these (0.05 sec)

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

       * The maximum number of requests to execute concurrently. Above this requests queue in memory,
       * waiting for the running calls to complete.
       *
       * If more than [maxRequests] requests are in flight when this is invoked, those requests will
       * remain in flight.
       */
      var maxRequests = 64
        get() = this.withLock { field }
        set(maxRequests) {
          require(maxRequests >= 1) { "max < 1: $maxRequests" }
          this.withLock {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. src/test/java/jcifs/tests/FileAttributesTest.java

                    f.setLastModified(time);
    
                    if ( ( getContext().getConfig().getCapabilities() & SmbConstants.CAP_NT_SMBS ) == 0 ) {
                        // only have second precision
                        // there seems to be some random factor (adding one second)
                        int diff = Math.abs((int) ( ( time / 1000 ) - ( f.lastModified() / 1000 ) ));
                        Assert.assertTrue("Have set time correctly", diff < 2);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:09:03 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  3. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java

          serverSocketChannel.configureBlocking(true);
          serverSocketChannel.socket().bind(address);
        }
    
        @Override public int getLocalPort() {
          return 1; // A white lie. There is no local port.
        }
    
        @Override public SocketAddress getLocalSocketAddress() {
          return endpoint;
        }
    
        @Override public Socket accept() throws IOException {
          try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 3.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/ForwardingListIterator.java

     * href="https://docs.oracle.com/javase/7/docs/api/java/util/ListIterator.html">before {@code
     * default} methods were introduced</a>. For newer methods, like {@code forEachRemaining}, it
     * inherits their default implementations. When those implementations invoke methods, they invoke
     * methods on the {@code ForwardingListIterator}.
     *
     * @author Mike Bostock
     * @since 2.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 29 19:42:21 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  5. compat/maven-compat/src/test/java/org/apache/maven/project/inheritance/t00/ProjectInheritanceTest.java

    /**
     * A test which demonstrates maven's recursive inheritance where
     * a distinct value is taken from each parent contributing to
     * the final model of the project being assembled. There is no
     * overriding going on amongst the models being used in this test:
     * each model in the lineage is providing a value that is not present
     * anywhere else in the lineage. We are just making sure that values
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ForwardingListeningExecutorService.java

     *
     * <p><b>{@code default} method warning:</b> This class does <i>not</i> forward calls to {@code
     * default} methods. Instead, it inherits their default implementations. When those implementations
     * invoke methods, they invoke methods on the {@code ForwardingListeningExecutorService}.
     *
     * @author Isaac Shum
     * @since 10.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  7. tests/test_tutorial/test_additional_responses/test_tutorial004.py

    client = TestClient(app)
    
    
    def test_path_operation():
        response = client.get("/items/foo")
        assert response.status_code == 200, response.text
        assert response.json() == {"id": "foo", "value": "there goes my hero"}
    
    
    def test_path_operation_img():
        shutil.copy("./docs/en/docs/img/favicon.png", "./image.png")
        response = client.get("/items/foo?img=1")
        assert response.status_code == 200, response.text
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jul 07 17:12:13 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/WinError.java

        };
    
        static final String[] WINERR_MESSAGES = {
            "The operation completed successfully.", "Access is denied.",
            "No more connections can be made to this remote computer at this time because there are already as many connections as the computer can accept.",
            "The pipe state is invalid.", "All pipe instances are busy.", "The pipe is being closed.", "No process is on the other end of the pipe.",
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.4K bytes
    - Viewed (0)
  9. src/main/java/jcifs/pac/kerberos/KerberosToken.java

                if ( !kerberosOid.getId().equals(KerberosConstants.KERBEROS_OID) )
                    throw new PACDecodingException("Not a kerberos token");
    
    
                // yes, there really is non ASN.1/DER data inside the tagged object
                int read = 0;
                int readLow = stream.read() & 0xff;
                int readHigh = stream.read() & 0xff;
                read = ( readHigh << 8 ) + readLow;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Oct 02 12:02:06 UTC 2023
    - 3K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/PeekingIterator.java

       * {@inheritDoc}
       *
       * <p>Implementations may or may not support removal when a call to {@link #peek()} has occurred
       * since the most recent call to {@link #next()}.
       *
       * @throws IllegalStateException if there has been a call to {@link #peek()} since the most recent
       *     call to {@link #next()} and this implementation does not support this sequence of calls
       *     (optional)
       */
      @Override
      void remove();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 24 17:47:51 UTC 2022
    - 2.5K bytes
    - Viewed (0)
Back to top