- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 725 for lose (0.03 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/ioutil/ioutil.go
return w.WriteCloser.Write(buf) }) w.err = err return n, err } // Close closer interface to close the underlying closer func (w *DeadlineWriter) Close() error { err := w.WriteCloser.Close() w.err = err if err == nil { w.err = errors.New("we are closed") // Avoids any reuse on the Write() side. } return err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 11.1K bytes - Click Count (0) -
src/main/java/org/codelibs/core/sql/StatementUtil.java
} /** * Closes the {@link Statement}. * <p> * If {@link Statement#close()} throws an exception, an error message is logged. The exception is not rethrown. * </p> * * @param statement * {@link Statement} * @see Statement#close() */ public static void close(final Statement statement) { if (statement == null) { return; }Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 5K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
resumeKey = rkresp.getResumeKey(); // start with some reasonably safe defaults, the server will till us if it does not like it // can we resume this if we loose the file descriptor? int maxChunks = 256; int maxChunkSize = 1024 * 1024; int byteLimit = 16 * 1024 * 1024; boolean retry = false; do {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 16.6K bytes - Click Count (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
MockResponse .Builder() .body("Hello!") .setHeader("Content-Type", PLAIN) .build(), ) val response = client.newCall(request().build()).execute() response.body.close() applicationLogs .assertLogEqual("--> GET $url") .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms, 6-byte body\)""")) .assertNoMoreLogs() networkLogsCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Nov 07 02:57:33 GMT 2025 - 39.4K bytes - Click Count (0) -
android/guava/src/com/google/common/io/MultiReader.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 2.4K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbTreeInternalTest.java
} @Test @DisplayName("unwrap and close are available via SmbTree") void unwrap_and_close_interactions() { // Arrange when(tree.unwrap(SmbTreeInternal.class)).thenReturn(tree); // Act SmbTree unwrapped = tree.unwrap(SmbTreeInternal.class); tree.close(); // Assert assertNotNull(unwrapped);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.6K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupContext.java
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jun 11 13:14:09 GMT 2025 - 5.7K bytes - Click Count (0) -
internal/dsync/dsync-client_test.go
u: u, rest: rest.NewClient(u, tr, nil), } } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) IsOnline() bool { // If rest client has not connected yet there is nothing to close. return restClient.rest != nil } func (restClient *ReconnectRESTClient) IsLocal() bool { return false } // Close closes the underlying socket file descriptor.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Click Count (0) -
internal/event/target/nats_tls_contrib_test.go
CertAuthority: path.Join("testdata", "contrib", "certs", "root_ca_cert.pem"), } con, err := clientConfig.connectNats() if err != nil { t.Errorf("Could not connect to nats: %v", err) } defer con.Close() } func TestNatsConnTLSCustomCAHandshakeFirst(t *testing.T) { s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls_handshake_first.conf")) defer s.Shutdown()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Apr 22 22:12:26 GMT 2025 - 2.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
*/ private val routePlanner = FakeRoutePlanner(taskFaker = taskFaker) private val finder = FastFallbackExchangeFinder(routePlanner, taskRunner) @AfterEach fun tearDown() { taskFaker.close() routePlanner.close() } @Test fun takeConnectedConnection() { val plan0 = routePlanner.addPlan() plan0.connectState = TLS_CONNECTED taskRunner.newQueue().execute("connect") {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 20.9K bytes - Click Count (0)