- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 369 for _flush (0.27 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/net/testing/http.go
return } defer conn.Close() if err := brw.Flush(); err != nil { h.t.Logf("Failed to flush pending writes to client, host=%s: %v", req.Host, err) return } if _, err := io.Copy(sconn, io.LimitReader(brw, int64(brw.Reader.Buffered()))); err != nil { h.t.Logf("Failed to flush buffered reads to server, host=%s: %v", req.Host, err) return } var wg sync.WaitGroup
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 20 14:58:46 UTC 2023 - 3.8K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
if err != nil { return } if len(mergeCh) == 0 { // Flush if nothing is queued w.(http.Flusher).Flush() } grid.PutByteBuffer(ev) case <-emptyEventTicker: if err := enc.Encode(struct{ Records []event.Event }{}); err != nil { return } w.(http.Flusher).Flush() case <-keepAliveTicker: if _, err := w.Write([]byte(" ")); err != nil { return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
src/net/http/cgi/child.go
rw.Write(nil) // make sure a response is sent if err = rw.bufw.Flush(); err != nil { return err } return nil } type response struct { req *http.Request header http.Header code int wroteHeader bool wroteCGIHeader bool bufw *bufio.Writer } func (r *response) Flush() { r.bufw.Flush() } func (r *response) Header() http.Header {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/source/PrintStreamLoggingSystem.java
public Snapshot setLevel(LogLevel logLevel) { Snapshot snapshot = snapshot(); if (logLevel != this.logLevel) { this.logLevel = logLevel; if (enabled) { outstr.flush(); outputEventListener.onOutput(new LogLevelChangeEvent(logLevel)); } } return snapshot; } @Override public Snapshot startCapture() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 5.9K bytes - Viewed (0) -
src/mime/quotedprintable/writer.go
w.line[w.i] = '=' w.i++ return w.insertCRLF() } func (w *Writer) insertCRLF() error { w.line[w.i] = '\r' w.line[w.i+1] = '\n' w.i += 2 return w.flush() } func (w *Writer) flush() error { if _, err := w.w.Write(w.line[:w.i]); err != nil { return err } w.i = 0 return nil } func isWhitespace(b byte) bool { return b == ' ' || b == '\t'
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 3.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CountingOutputStream.java
out.write(b); count++; } // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior: // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream. // It should flush itself if necessary. @Override public void close() throws IOException { out.close(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 2K bytes - Viewed (0) -
guava/src/com/google/common/hash/HashingOutputStream.java
return hasher.hash(); } // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior: // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream. // It should flush itself if necessary. @Override public void close() throws IOException { out.close(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 20 18:43:59 UTC 2021 - 2.6K bytes - Viewed (0) -
src/net/textproto/writer.go
// PrintfLine writes the formatted output followed by \r\n. func (w *Writer) PrintfLine(format string, args ...any) error { w.closeDot() fmt.Fprintf(w.W, format, args...) w.W.Write(crnl) return w.W.Flush() } // DotWriter returns a writer that can be used to write a dot-encoding to w. // It takes care of inserting leading dots when necessary, // translating line-ending \n into \r\n, and adding the final .\r\n line
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ReaderInputStream.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 9.3K bytes - Viewed (0) -
guava/src/com/google/common/io/ReaderInputStream.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 9.3K bytes - Viewed (0)