Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 158 for closures (0.06 seconds)

  1. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/ThirdPartyAuditTask.java

                // Each extract will overwrite the top level classes that existed before it, the result is that we end up
                // with a single version of the class in `jarExpandDir`.
                // This will be the closes version to `targetCompatibility`, the same class that would be loaded in a JVM
                // that has `targetCompatibility` version.
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Jun 17 08:59:22 GMT 2021
    - 16.2K bytes
    - Click Count (0)
  2. 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 Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jun 19 11:44:16 GMT 2025
    - 19.1K 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 Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K 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 Apr 05 19:28:12 GMT 2026
    - 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  6. src/bytes/bytes.go

    // punctuation properly. Use golang.org/x/text/cases instead.
    func Title(s []byte) []byte {
    	// Use a closure here to remember state.
    	// Hackish but effective. Depends on Map scanning in order and calling
    	// the closure once per rune.
    	prev := ' '
    	return Map(
    		func(r rune) rune {
    			if isSeparator(prev) {
    				prev = r
    				return unicode.ToTitle(r)
    			}
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Mar 12 17:56:55 GMT 2026
    - 36.3K bytes
    - Click Count (0)
  7. src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java

        }
    
        @Test
        @DisplayName("Should handle multiple closes gracefully")
        void testMultipleCloses() {
            // Given
            Smb2EncryptionContext context = new Smb2EncryptionContext(EncryptionNegotiateContext.CIPHER_AES128_CCM, DialectVersion.SMB300,
                    testEncryptionKey, testDecryptionKey);
    
            // When/Then - Multiple closes should be safe
            assertDoesNotThrow(() -> {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 44.1K bytes
    - Click Count (0)
  8. src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTest.java

            // Cannot check password after closing as it now throws IllegalStateException
            // This is actually good security practice - closed authenticators cannot be accessed
    
            // Verify multiple closes don't cause issues
            auth.close(); // Should be safe to call again
            assertTrue(auth.isClosed());
        }
    
        /**
         * Test AutoCloseable implementation
         */
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 23.3K bytes
    - Click Count (0)
  9. docs/fr/docs/help-fastapi.md

    * Dans de nombreux cas, il est préférable de comprendre leur **problème sous‑jacent ou cas d'utilisation**, car il pourrait exister une meilleure façon de le résoudre que ce qu'ils essaient de faire.
    
    ### Demander la clôture { #ask-to-close }
    
    S'ils répondent, il y a de fortes chances que vous ayez résolu leur problème, bravo, **vous êtes un héros** ! 🦸
    
    * Maintenant, si cela a résolu leur problème, vous pouvez leur demander de :
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 14.6K bytes
    - Click Count (0)
  10. 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 Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Feb 26 17:14:40 GMT 2026
    - 13.2K bytes
    - Click Count (0)
Back to Top