- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 2,280 for bread (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
frameCallback.onReadMessage(messageFrameBuffer.readByteString()) } } /** Read headers and process any control frames until we reach a non-control frame. */ @Throws(IOException::class) private fun readUntilNonControlFrame() { while (!closed) { readHeader() if (!isControlFrame) { break } readControlFrame() } } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
internal/s3select/csv/recordtransform.go
recordDelimiter []byte oneByte []byte useOneByte bool } func (rr *recordTransform) Read(p []byte) (n int, err error) { if rr.useOneByte { p[0] = rr.oneByte[0] rr.useOneByte = false n, err = rr.reader.Read(p[1:]) n++ } else { n, err = rr.reader.Read(p) } if err != nil { return n, err } // Do nothing if record-delimiter is already newline.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.1K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
v, err = cr.reader.ReadByte() if err != nil { if err == io.EOF { return io.ErrUnexpectedEOF } } if v != '\n' { return errMalformedEncoding } break } // Read signature var signatureBuffer bytes.Buffer for { v, err := cr.reader.ReadByte() if err != nil { if err == io.EOF { return io.ErrUnexpectedEOF } } if v != '\r' {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
} // Re-loop in case of errors. break; case FetchState::FINISHED: return TF_SetStatus(status, TF_OK, ""); } } return TF_SetStatus( status, TF_INTERNAL, "Control flow should never reach the end of RamFileBlockCache::Fetch."); } int64_t RamFileBlockCache::Read(const std::string& filename, size_t offset,
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Jul 16 01:39:09 GMT 2020 - 11.1K bytes - Viewed (0) -
src/bufio/scan_test.go
// on a reader that returns a negative count of bytes read (issue 38053). func TestNegativeEOFReader(t *testing.T) { r := negativeEOFReader(10) scanner := NewScanner(&r) c := 0 for scanner.Scan() { c++ if c > 1 { t.Error("read too many lines") break } } if got, want := scanner.Err(), ErrBadReadCount; got != want {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0) -
cmd/erasure-decode.go
canDecode := p.canDecode(newBuf) newBufLK.RUnlock() if canDecode { break } if readerIndex == len(p.readers) { break } if !readTrigger { continue } wg.Add(1) go func(i int) { defer wg.Done() rr := p.readers[i] if rr == nil { // Since reader is nil, trigger another read. readTriggerCh <- true return } bufIdx := p.readerToBuf[i]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/perf-tests.go
} type firstByteRecorder struct { t *time.Time r io.Reader } func (f *firstByteRecorder) Read(p []byte) (n int, err error) { if f.t != nil || len(p) == 0 { return f.r.Read(p) } // Read a single byte. n, err = f.r.Read(p[:1]) if n > 0 { t := time.Now() f.t = &t } return n, err } // Runs the speedtest on local MinIO process.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteStreams.java
int off = (int) expectedSize - remaining; int read = in.read(bytes, off, remaining); if (read == -1) { // end of stream before reading expectedSize bytes // just return the bytes read so far return Arrays.copyOf(bytes, off); } remaining -= read; } // bytes is now full int b = in.read(); if (b == -1) { return bytes; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jan 17 18:59:58 GMT 2024 - 29.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
android/guava/src/com/google/thirdparty/publicsuffix/TrieParser.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Oct 13 19:20:43 GMT 2022 - 4K bytes - Viewed (0)