- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 800 for completes (0.07 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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 structureCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 5.4K bytes - Click Count (0) -
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) -
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) -
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)