Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 365 for closing (0.33 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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-channel
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 20K bytes
    - Viewed (0)
Back to top