Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 175 for encloses (0.06 seconds)

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

       * - Both request discover no existing connection. They both make a connection.
       * - The first request "wins the race".
       * - The second request discovers it "lost the race" and closes the connection it just opened.
       * - The second request uses the coalesced connection from request1.
       * - The coalesced connection is violently closed after servicing the first request.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jun 19 11:44:16 GMT 2025
    - 19.1K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/HttpUrl.kt

     *
     * [Punycode](http://ietf.org/rfc/rfc3492.txt) converts a Unicode string to an ASCII string to make
     * international domain names work everywhere. For example, "σ" encodes as "xn--4xa". The encoded
     * string is not human readable, but can be used with classes like [InetAddress] to establish
     * connections.
     *
     * ## Why another URL model?
     *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon May 05 16:01:00 GMT 2025
    - 63.5K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

      override fun clone(): Call = RealCall(client, originalRequest, forWebSocket)
    
      override fun request(): Request = originalRequest
    
      /**
       * Immediately closes the socket connection if it's currently held. Use this to interrupt an
       * in-flight request from any thread. It's the caller's responsibility to close the request body
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  4. internal/rest/client.go

    	return c.CallWithHTTPMethod(ctx, http.MethodPost, rpcMethod, values, body, length)
    }
    
    // Close closes all idle connections of the underlying http client
    func (c *Client) Close() {
    	atomic.StoreInt32(&c.connected, closed)
    }
    
    // NewClient - returns new REST client.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  5. internal/s3select/message.go

    		progressTickerC = progressTicker.C
    	}
    	recordStagingTicker := time.NewTicker(500 * time.Millisecond)
    
    	// Exit conditions:
    	//
    	// 1. If a writer.write() returns false, select loop below exits and
    	// closes `doneCh` to indicate to caller to also exit.
    	//
    	// 2. If caller (Evaluate()) has an error, it sends an error
    	// message and waits for this go-routine to quit in
    	// FinishWithError()
    	//
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  6. src/builtin/builtin.go

    // contain only map or slice types, and clear performs the operation
    // implied by the type argument. If t is nil, clear is a no-op.
    func clear[T ~[]Type | ~map[Type]Type1](t T)
    
    // The close built-in function closes a channel, which must be either
    // bidirectional or send-only. It should be executed only by the sender,
    // never the receiver, and has the effect of shutting down the channel after
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 30 23:59:23 GMT 2024
    - 12.8K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/primitives/IntsTest.java

        }
        assertWithMessage("Hex string and dec parm").that(Ints.tryParse("FFFF", 10)).isNull();
        assertWithMessage("Mixed hex case").that((int) Ints.tryParse("ffFF", 16)).isEqualTo(65535);
      }
    
      /**
       * Encodes an integer as a string with given radix, then uses {@link Ints#tryParse(String, int)}
       * to parse the result. Asserts the result is the same as what we started with.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 29.3K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * This is typically invoked immediately before bytes are returned to the application. If the
       * response body is empty this is invoked immediately before returning that to the application.
       *
       * If the application closes the response body before attempting a read, this is invoked at the
       * time it is closed.
       *
       * The connection is implicit, and will generally relate to the last [connectionAcquired] event.
       *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  9. src/archive/zip/writer.go

    		FileHeader: fh,
    		offset:     uint64(w.cw.count),
    	}
    
    	if strings.HasSuffix(fh.Name, "/") {
    		// Set the compression method to Store to ensure data length is truly zero,
    		// which the writeHeader method always encodes for the size fields.
    		// This is necessary as most compression formats have non-zero lengths
    		// even when compressing an empty string.
    		fh.Method = Store
    		fh.Flags &^= 0x8 // we will not write a data descriptor
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

       *
       * This same problem is one of the reasons for us to likewise use package-private for the fields
       * in Waiter.
       */
    
      /**
       * This field encodes the current state of the future.
       *
       * <p>The valid values are:
       *
       * <ul>
       *   <li>{@code null} initial state, nothing has happened.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
Back to Top