Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 800 for completes (0.06 seconds)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    	response, err = x.ClientConversation.Step(challenge)
    	return response, err
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/fess/helper/ProcessHelperTest.java

                assertNotNull(jobProcess2);
                // Since echo command completes quickly, processes might already be finished
                // So we just verify that processes were created without errors
    
                Set<String> sessionIds = processHelper.getRunningSessionIdSet();
                // Since echo commands complete quickly, we may not catch them running
                // Just verify no exceptions occurred
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 16K bytes
    - Click Count (0)
  3. internal/event/target/kafka_scram_client_contrib.go

    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    	response, err = x.ClientConversation.Step(challenge)
    	return response, err
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/validation/CronExpressionValidatorTest.java

                    "0 0 0 1 13 ?", // Invalid month
            };
    
            for (String cron : edgeCases) {
                boolean result = validator.determineValid(cron);
                // Test that validation completes without exception
                assertNotNull(Boolean.valueOf(result), "Validation should return a boolean result for edge case: " + cron);
            }
        }
    
        @Test
        public void test_constructorAndInitialize() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  5. CONTRIBUTING.md

    - To run `make verifiers`
    - To squash your commits into a single commit. `git rebase -i`. It's okay to force update your pull request.
    - To run `make test` and `make build` completes.
    
    ### Commit changes
    
    After verification, commit your changes. This is a [great post](https://chris.beams.io/posts/git-commit/) on how to write useful commit messages
    
    ```
    git commit -am 'Add some feature'
    ```
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Aug 05 18:35:53 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  6. build-tools-internal/src/main/groovy/elasticsearch.build-scan.gradle

          }
        }
    
        // Jenkins-specific build scan metadata
        if (jenkinsUrl) {
          // Disable async upload in CI to ensure scan upload completes before CI agent is terminated
          uploadInBackground = false
    
          // Parse job name in the case of matrix builds
          // Matrix job names come in the form of "base-job-name/matrix_param1=value1,matrix_param2=value2"
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Jul 21 20:40:34 GMT 2021
    - 4.6K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/validation/CustomSizeValidatorTest.java

        }
    
        @Test
        public void test_initialize_withValidParameters() {
            final CustomSize annotation = createBasicAnnotation();
            validator.initialize(annotation);
            // Test that initialization completes without exception
        }
    
        @Test
        public void test_classStructure() {
            // Test that the class exists and has the expected structure
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 5.4K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

       */
      private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>()
    
      /**
       * Results are posted here as they occur. The find job is done when either one plan completes
       * successfully or all plans fail.
       */
      private val connectResults = taskRunner.backend.decorate(LinkedBlockingDeque<ConnectResult>())
    
      override fun find(): RealConnection {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  9. src/test/java/jcifs/dcerpc/msrpc/SamrAliasHandleTest.java

            // We cannot directly access private fields of MsrpcSamrOpenAlias or its superclass
            // Instead, we verify the interaction with the DcerpcHandle and the return value.
            // The fact that the constructor completes without exception and sets 'opened' to true
            // implies the correct parameters were used internally.
        }
    
        @Test
        void constructor_shouldThrowSmbExceptionOnOpenFailure() throws IOException {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  10. src/main/java/jcifs/internal/witness/WitnessClient.java

         *
         * @param shareName the share name to monitor
         * @param serverAddress the server address
         * @param listener the notification listener
         * @return a future that completes with the registration
         */
        public CompletableFuture<WitnessRegistration> registerForNotifications(String shareName, InetAddress serverAddress,
                WitnessNotificationListener listener) {
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 20.8K bytes
    - Click Count (0)
Back to Top