- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 438 for readlink (0.12 sec)
-
android/guava-tests/test/com/google/common/io/FilesSimplifyPathTest.java
private void doExtensiveTest(String resourceName) throws IOException { Splitter splitter = Splitter.on(CharMatcher.whitespace()); URL url = getClass().getResource(resourceName); for (String line : Resources.readLines(url, UTF_8)) { Iterator<String> iterator = splitter.split(line).iterator(); String input = iterator.next(); String expectedOutput = iterator.next(); assertFalse(iterator.hasNext());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 10.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/FilesSimplifyPathTest.java
private void doExtensiveTest(String resourceName) throws IOException { Splitter splitter = Splitter.on(CharMatcher.whitespace()); URL url = getClass().getResource(resourceName); for (String line : Resources.readLines(url, UTF_8)) { Iterator<String> iterator = splitter.split(line).iterator(); String input = iterator.next(); String expectedOutput = iterator.next(); assertFalse(iterator.hasNext());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 10.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
try { GzipSource(fileSystem.source(path)).buffer().use { bufferedSource -> val totalBytes = bufferedSource.readInt() publicSuffixListBytes = bufferedSource.readByteArray(totalBytes.toLong()) val totalExceptionBytes = bufferedSource.readInt() publicSuffixExceptionListBytes = bufferedSource.readByteArray(totalExceptionBytes.toLong()) } synchronized(this) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* ... // Handle the failure. * } * }); * ``` * * These examples will not work if you're consuming the response body on another thread. In such * cases the consuming thread must call [close] when it has finished reading the response * body. * * ### The response body can be consumed only once. * * This class may be used to stream very large responses. For example, it is possible to use this
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/Cut.java
* use the `endpoint` field, compareTo() and endpoint(). Additionally, the main implementation * of Cut.compareTo checks for belowAll before reading accessing `endpoint` on another Cut * instance. */ super(""); } @Override Comparable<?> endpoint() { throw new IllegalStateException("range unbounded on this side");
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 16 17:21:56 UTC 2024 - 12.2K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// The s3ChunkedReader returns io.EOF when the final 0-length chunk is read. // // NewChunkedReader is not needed by normal applications. The http package // automatically decodes chunking when reading response bodies. func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) { cred, seedSignature, region, seedDate, errCode := calculateSeedSignature(req, trailer) if errCode != ErrNone {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 18.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileInputStream.java
this(new SmbFile(url, tc), 0, SmbConstants.O_RDONLY, SmbConstants.DEFAULT_SHARING, true); } /** * Creates an {@link java.io.InputStream} for reading bytes from a file on * an SMB server represented by the {@link jcifs.smb.SmbFile} parameter. See * {@link jcifs.smb.SmbFile} for a detailed description and examples of * the smb URL syntax. *
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun May 17 08:55:14 UTC 2020 - 13.2K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
} // Target - Kafka target. type Target struct { status int32 totalMessages int64 failedMessages int64 wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
guava/src/com/google/common/base/Stopwatch.java
/** * An object that accurately measures <i>elapsed time</i>: the measured duration between two * successive readings of "now" in the same process. * * <p>In contrast, <i>wall time</i> is a reading of "now" as given by a method like * {@link System#currentTimeMillis()}, best represented as an {@link java.time.Instant}. Such values * <i>can</i> be subtracted to obtain a {@code Duration} (such as by {@code Duration.between}), but
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 9.3K bytes - Viewed (0) -
guava/src/com/google/common/collect/TreeMultimap.java
stream.writeObject(valueComparator()); Serialization.writeMultimap(this, stream); } @GwtIncompatible // java.io.ObjectInputStream @J2ktIncompatible @SuppressWarnings("unchecked") // reading data stored by writeObject private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Mar 09 00:21:17 UTC 2024 - 8.7K bytes - Viewed (0)