- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 2,133 for Read (0.16 sec)
-
guava-tests/test/com/google/common/io/TestInputStream.java
public boolean closed() { return closed; } @Override public int read() throws IOException { throwIf(closed); throwIf(READ_THROWS); return in.read(); } @Override public int read(byte[] b, int off, int len) throws IOException { throwIf(closed); throwIf(READ_THROWS); return in.read(b, off, len); } @Override public long skip(long n) throws IOException {
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LineReader.java
// The default implementation of Reader#read(CharBuffer) allocates a // temporary char[], so we call Reader#read(char[], int, int) instead. int read = (reader != null) ? reader.read(buf, 0, buf.length) : readable.read(cbuf); if (read == -1) { lineBuf.finish(); break; } lineBuf.add(buf, 0, read); } return lines.poll(); }
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
"time" ) // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout. type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. writeDeadline time.Duration // sets the write deadline on a connection. } // Sets read deadline func (c *DeadlineConn) setReadDeadline() { if c.readDeadline > 0 {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
assertThat(inputStream!!.read()).isEqualTo('A'.code) assertThat(inputStream.read()).isEqualTo('B'.code) assertThat(inputStream.read()).isEqualTo('C'.code) assertThat(inputStream.read()).isEqualTo('D'.code) assertThat(inputStream.read()).isEqualTo('E'.code) assertThat(inputStream.read()).isEqualTo('F'.code) assertThat(inputStream.read()).isEqualTo(-1)
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.5K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
type MonitorReaderOptions struct { BucketOptions HeaderSize int } // Read implements a throttled read func (r *MonitoredReader) Read(buf []byte) (n int, err error) { if r.throttle == nil { return r.r.Read(buf) } if r.lastErr != nil { err = r.lastErr return } b := r.throttle.Burst() // maximum available tokens
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComOpenAndX.java
} else if ( ( shareAccess & SmbConstants.FILE_SHARE_READ ) == 0 ) { this.desiredAccess |= SHARING_DENY_READ_EXECUTE; } else { // neither SHARE_READ nor SHARE_WRITE are set this.desiredAccess |= SHARING_DENY_READ_WRITE_EXECUTE; } this.desiredAccess &= ~0x1; // Win98 doesn't like GENERIC_READ ?! -- get Access Denied. // searchAttributes
Java - Registered: Sun Mar 24 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/FileOperator.kt
import java.nio.channels.FileChannel import okio.Buffer /** * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)` * this class offers: * * * **Read/write:** read and write using the same operator. * * **Random access:** access any position within the file. * * **Shared channels:** read and write a file channel that's shared between
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/FileBackedOutputStreamTest.java
ByteSource source = out.asByteSource(); out.write(data); assertTrue(Arrays.equals(data, source.read())); out.reset(); assertTrue(Arrays.equals(new byte[0], source.read())); out.write(data); assertTrue(Arrays.equals(data, source.read())); out.close(); } private static boolean isAndroid() {
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 5.5K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem_test.cc
std::string result; result.resize(6); int64_t read = tf_random_access_file::Read(file, 0, 6, &result[0], status_); ASSERT_EQ(read, 6) << "Read: " << read << "\n"; ASSERT_TF_OK(status_); ASSERT_EQ(result, "012345") << "Result: " << result << "\n"; read = tf_random_access_file::Read(file, 6, 6, &result[0], status_); ASSERT_EQ(read, 4) << "Read: " << read << "\n";
C++ - Registered: Tue Mar 26 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 12:04:23 GMT 2020 - 24.9K bytes - Viewed (0) -
internal/s3select/csv/reader.go
dst chan [][]string // result of block decode err error // any error encountered will be set here } // Read - reads single record. // Once Read is called the previous record should no longer be referenced. func (r *Reader) Read(dst sql.Record) (sql.Record, error) { // If we have have any records left, return these before any error. for len(r.current) <= r.recordsRead { if r.err != nil {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0)