- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 84 for flushed (0.25 sec)
-
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) -
src/hash/maphash/maphash.go
type Hash struct { _ [0]func() // not comparable seed Seed // initial seed used for this hash state Seed // current hash of all flushed bytes buf [bufSize]byte // unflushed byte buffer n int // number of unflushed bytes } // bufSize is the size of the Hash write buffer. // The buffer ensures that writes depend only on the sequence of bytes,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 19:15:34 UTC 2023 - 7.9K bytes - Viewed (0) -
src/compress/lzw/reader.go
// Non-literal codes decode to a sequence of suffixes that are first // written right-to-left from the end of the buffer before being copied // to the start of the buffer. // It is flushed when it contains >= 1<<maxWidth bytes, // so that there is always room to decode an entire code. output [2 * 1 << maxWidth]byte o int // write index into output toRead []byte // bytes to return from Read }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:39 UTC 2023 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flushwriter/writer.go
package flushwriter import ( "io" "net/http" ) // Wrap wraps an io.Writer into a writer that flushes after every write if // the writer implements the Flusher interface. func Wrap(w io.Writer) io.Writer { fw := &flushWriter{ writer: w, } if flusher, ok := w.(http.Flusher); ok { fw.flusher = flusher } return fw } // flushWriter provides wrapper for responseWriter with HTTP streaming capabilities
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 05 16:09:42 UTC 2017 - 1.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flushwriter/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package flushwriter implements a wrapper for a writer that flushes on every // write if that writer implements the io.Flusher interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 05 16:14:27 UTC 2017 - 780 bytes - Viewed (0) -
src/net/http/responsecontroller.go
} type rwUnwrapper interface { Unwrap() ResponseWriter } // Flush flushes buffered data to the client. func (c *ResponseController) Flush() error { rw := c.rw for { switch t := rw.(type) { case interface{ FlushError() error }: return t.FlushError() case Flusher: t.Flush() return nil case rwUnwrapper: rw = t.Unwrap() default: return errNotSupported()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper.go
} func (wr outerWithCloseNotifyAndFlush) Flush() { if flusher, ok := wr.UserProvidedDecorator.(http.Flusher); ok { flusher.Flush() return } wr.InnerCloseNotifierFlusher.Flush() } //lint:file-ignore SA1019 Keep supporting deprecated http.CloseNotifier var _ http.CloseNotifier = outerWithCloseNotifyFlushAndHijack{} var _ http.Flusher = outerWithCloseNotifyFlushAndHijack{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/FlushConsoleListener.java
import org.gradle.internal.logging.events.OutputEvent; import org.gradle.internal.logging.events.OutputEventListener; import org.gradle.internal.logging.events.UpdateNowEvent; /** * Flushes the console output. Used when no other listener in the chain flushes the console. */ public class FlushConsoleListener implements OutputEventListener { private final OutputEventListener delegate; private final Console console;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper_test.go
// the http.ResponseWriter object for both http/1.x and http2 // implement http.Flusher and http.CloseNotifier if _, ok := w.(http.Flusher); !ok { t.Errorf("Expected the http.ResponseWriter object to implement http.Flusher") } //nolint:staticcheck // SA1019 if _, ok := w.(http.CloseNotifier); !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:53 UTC 2021 - 8.1K bytes - Viewed (0) -
doc/next/6-stdlib/99-minor/runtime/trace/65319.md
<!-- go.dev/issue/65319 --> The runtime now explicitly flushes trace data when a program crashes due to an uncaught panic. This means that more complete trace data will be available in a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:37:09 UTC 2024 - 241 bytes - Viewed (0)