- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 849 for flushF (0.11 sec)
-
src/cmd/vendor/golang.org/x/text/unicode/norm/composition.go
func (rb *reorderBuffer) setFlusher(out []byte, f func(*reorderBuffer) bool) { rb.out = out rb.flushF = f } // reset discards all characters from the buffer. func (rb *reorderBuffer) reset() { rb.nrune = 0 rb.nbyte = 0 } func (rb *reorderBuffer) doFlush() bool { if rb.f.composing { rb.compose() } res := rb.flushF(rb) rb.reset() return res }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 14.1K bytes - Viewed (0) -
src/vendor/golang.org/x/text/unicode/norm/composition.go
func (rb *reorderBuffer) setFlusher(out []byte, f func(*reorderBuffer) bool) { rb.out = out rb.flushF = f } // reset discards all characters from the buffer. func (rb *reorderBuffer) reset() { rb.nrune = 0 rb.nbyte = 0 } func (rb *reorderBuffer) doFlush() bool { if rb.f.composing { rb.compose() } res := rb.flushF(rb) rb.reset() return res }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 19:27:51 UTC 2019 - 14.1K bytes - Viewed (0) -
src/vendor/golang.org/x/text/unicode/norm/normalize.go
ft := formTable[f] n, ok := ft.quickSpan(src, 0, len(b), true) if ok { return b } out := make([]byte, n, len(b)) copy(out, b[0:n]) rb := reorderBuffer{f: *ft, src: src, nsrc: len(b), out: out, flushF: appendFlush} return doAppendInner(&rb, n) } // String returns f(s). func (f Form) String(s string) string { src := inputString(s) ft := formTable[f] n, ok := ft.quickSpan(src, 0, len(s), true) if ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 16 22:26:23 UTC 2022 - 14.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/normalize.go
ft := formTable[f] n, ok := ft.quickSpan(src, 0, len(b), true) if ok { return b } out := make([]byte, n, len(b)) copy(out, b[0:n]) rb := reorderBuffer{f: *ft, src: src, nsrc: len(b), out: out, flushF: appendFlush} return doAppendInner(&rb, n) } // String returns f(s). func (f Form) String(s string) string { src := inputString(s) ft := formTable[f] n, ok := ft.quickSpan(src, 0, len(s), true) if ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 14.9K 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) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/ThrottlingOutputEventListenerTest.groovy
10_000 * listener.onOutput(_) } def "background flush does nothing when events already flushed"() { def event1 = event('1') def event2 = event('2') def flush = new FlushOutputEvent() given: renderer.onOutput(event1) renderer.onOutput(event2) renderer.onOutput(flush) when: executor.runFixedScheduledActionsNow()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 4.6K 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) -
src/compress/zlib/writer.go
if err != nil { z.err = err return } z.digest.Write(p) return } // Flush flushes the Writer to its underlying io.Writer. func (z *Writer) Flush() error { if !z.wroteHeader { z.err = z.writeHeader() } if z.err != nil { return z.err } z.err = z.compressor.Flush() return z.err } // Close closes the Writer, flushing any unwritten data to the underlying
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 27 18:51:27 UTC 2023 - 5.2K bytes - Viewed (0) -
src/net/http/httptest/recorder.go
if rw.HeaderMap == nil { rw.HeaderMap = make(http.Header) } rw.snapHeader = rw.HeaderMap.Clone() } // Flush implements [http.Flusher]. To test whether Flush was // called, see rw.Flushed. func (rw *ResponseRecorder) Flush() { if !rw.wroteHeader { rw.WriteHeader(200) } rw.Flushed = true } // Result returns the response generated by the handler. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7K bytes - Viewed (0) -
src/compress/gzip/gzip.go
n, z.err = z.compressor.Write(p) return n, z.err } // Flush flushes any pending compressed data to the underlying writer. // // It is useful mainly in compressed network protocols, to ensure that // a remote reader has enough data to reconstruct a packet. Flush does // not return until the data has been written. If the underlying // writer returns an error, Flush returns that error. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 6.2K bytes - Viewed (0)