- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 365 for closing (0.03 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
* An HTTP response. Instances of this class are not immutable: the response body is a one-shot * value that may be consumed only once and then closed. All other properties are immutable. * * This class implements [Closeable]. Closing it simply closes its response body. See * [ResponseBody] for an explanation and examples. */ class Response internal constructor( /**
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jul 28 14:39:28 UTC 2025 - 18.1K bytes - Viewed (0) -
src/archive/zip/writer_test.go
if err != nil { t.Fatalf("opening %s: %v", f.Name, err) } b, err := io.ReadAll(rc) if err != nil { t.Fatalf("reading %s: %v", f.Name, err) } err = rc.Close() if err != nil { t.Fatalf("closing %s: %v", f.Name, err) } if !bytes.Equal(b, wt.Data) { t.Errorf("File contents %q, want %q", b, wt.Data) } } func BenchmarkCompressedZipGarbage(b *testing.B) {Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Jan 28 04:20:09 UTC 2025 - 14.4K bytes - Viewed (0) -
internal/grid/connection.go
defer c.connMu.Unlock() if c.debugInConn != nil { if debugPrint { fmt.Println("debug: closing inbound connection") } c.debugInConn.Close() } case debugKillOutbound: c.connMu.Lock() defer c.connMu.Unlock() if c.debugInConn != nil { if debugPrint { fmt.Println("debug: closing outgoing connection") } c.debugInConn.Close() } case debugWaitForExit:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 46.9K bytes - Viewed (0) -
cmd/sftp-server-driver.go
switch { case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue") _ = w.w.CloseWithError(err) case w.err != nil: // No need to close here since both pipes were // closing inside TransferError() err = w.err default: err = w.w.Close() } for i := range w.buffer { delete(w.buffer, i) } w.wg.Wait() return err } type writerAt struct {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0) -
internal/event/target/nats.go
} return target.store.Del(key) } // Close - closes underneath connections to NATS server. func (target *NATSTarget) Close() (err error) { close(target.quitCh) if target.stanConn != nil { // closing the streaming connection does not close the provided NATS connection. if target.stanConn.NatsConn() != nil { target.stanConn.NatsConn().Close() } return target.stanConn.Close() }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Apr 27 04:30:57 UTC 2025 - 13.5K bytes - Viewed (0) -
docs/ru/docs/tutorial/dependencies/dependencies-with-yield.md
# Зависимости с yield { #dependencies-with-yield } FastAPI поддерживает зависимости, которые выполняют некоторые <abbr title='иногда также называемые "exit code", "cleanup code", "teardown code", "closing code", "context manager exit code" и т.п.'>дополнительные шаги после завершения</abbr>. Для этого используйте `yield` вместо `return`, а дополнительные шаги (код) напишите после него. /// tip | ПодсказкаRegistered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 19.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeConnection.java
* It delegates to the release() method to properly clean up the connection. */ @Override public void close() { if (log.isDebugEnabled()) { log.debug("Closing SmbTreeConnection via AutoCloseable.close()"); } release(); } protected void checkRelease() { if (isConnected() && this.usageCount.get() != 0) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 30.4K bytes - Viewed (1) -
cmd/metacache-stream.go
metaDataPoolPut(o.metadata) } } return nil } // stream entries to the output. // The returned channel should be closed when done. // Any error is reported when closing the metacacheWriter. func (w *metacacheWriter) stream() (chan<- metaCacheEntry, error) { if w.creator != nil { err := w.creator() w.creator = nil if err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed May 07 15:37:12 UTC 2025 - 19.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
if (channel.getTransport() != null) { channel.getTransport().disconnect(true); } } catch (Exception e) { log.warn("Error closing channel {}: {}", channel.getChannelId(), e.getMessage()); } } log.info("Removed {} channels for session {}", channelGroup.getChannelCount(), sessionId); } }
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 20.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
for (ChannelInfo channel : channels.values()) { try { channel.getTransport().close(); } catch (Exception e) { log.debug("Error closing channel", e); } } channels.clear(); } private boolean supportsMultiChannel() { // Check if both client and server support multi-channelRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0)