- Sort Score
- Num 10 results
- Language All
Results 191 - 200 of 1,031 for readOp (0.06 seconds)
-
src/main/java/org/codelibs/core/io/LineIterator.java
return () -> new LineIterator(reader); } /** * Constructs an instance. * * @param reader * The {@link Reader} to read strings from. Must not be {@literal null}. */ public LineIterator(final Reader reader) { assertArgumentNotNull("reader", reader); this.reader = new BufferedReader(reader); } /**Created: Sat Dec 20 08:55:33 GMT 2025 - Last Modified: Thu Jun 19 09:12:22 GMT 2025 - 3.6K bytes - Click Count (0) -
android/guava/src/com/google/common/io/LineReader.java
Java8Compatibility.clear(cbuf); // 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(); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/XmlFactory.java
} @Nonnull default T read(@Nonnull InputStream input, boolean strict) throws XmlReaderException { return read(XmlReaderRequest.builder().inputStream(input).strict(strict).build()); } @Nonnull default T read(@Nonnull Reader reader) throws XmlReaderException { return read(reader, true); } @NonnullCreated: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 3.9K bytes - Click Count (0) -
compat/maven-toolchain-model/src/main/java/org/apache/maven/toolchain/model/io/xpp3/MavenToolchainsXpp3Reader.java
*/ public PersistedToolchains read(Reader reader) throws IOException, XmlPullParserException { return read(reader, true); } /** * Method read. * * @param in a in object. * @param strict a strict object. * @return PersistedToolchains * @throws IOException IOException if any. * @throws XmlPullParserException XmlPullParserException if * any.Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat May 31 10:30:45 GMT 2025 - 5K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
} override fun fromDer(reader: DerReader): Any? { if (isOptional && !reader.hasNext()) return optionalValue val peekedHeader = reader.peekHeader() ?: throw ProtocolException("expected a value at $reader") for ((_, adapter) in choices) { if (adapter.matches(peekedHeader)) { return adapter.fromDer(reader) } }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15K bytes - Click Count (0) -
src/main/java/org/codelibs/core/io/PropertiesUtil.java
} /** * Wraps exception handling for {@link Properties#load(Reader)}. * <p> * The input reader is not closed. * </p> * * @param props the property set (must not be {@literal null}) * @param reader the input reader (must not be {@literal null}) */ public static void load(final Properties props, final Reader reader) { assertArgumentNotNull("props", props);Created: Sat Dec 20 08:55:33 GMT 2025 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 7.9K bytes - Click Count (0) -
compat/maven-settings/src/main/java/org/apache/maven/settings/io/xpp3/SettingsXpp3Reader.java
} public Settings read(Reader reader, boolean strict) throws IOException, XmlPullParserException { try { return new Settings(delegate.read(reader, strict, null)); } catch (XMLStreamException e) { throw new XmlPullParserException(e.getMessage(), null, e); } } public Settings read(Reader reader) throws IOException, XmlPullParserException { try {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 4K bytes - Click Count (0) -
internal/dsync/drwmutex_test.go
panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(t.Context()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/ioutil/read_file.go
_, err = io.ReadFull(f, dst) return dst, st, err } // ReadFile reads the named file and returns the contents. // A successful call returns err == nil, not err == EOF. // Because ReadFile reads the whole file, it does not treat an EOF from Read // as an error to be reported. // // passes NOATIME flag for reads on Unix systems to avoid atime updates. func ReadFile(name string) ([]byte, error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt
override fun fromDer(reader: DerReader): T { val peekedHeader = reader.peekHeader() if (peekedHeader == null || peekedHeader.tagClass != tagClass || peekedHeader.tag != tag) { if (isOptional) return defaultValue as T throw ProtocolException("expected $this but was $peekedHeader at $reader") } val result = reader.read(name) { codec.decode(reader) }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.4K bytes - Click Count (0)