- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 285 for reader_r (0.14 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/s3select/select.go
return rsc.offset, errors.New("seek past end of object") } if rsc.reader != nil { _ = rsc.reader.Close() rsc.reader = nil } return rsc.offset, nil } // Read call to implement io.Reader func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) { if rsc.reader == nil { rsc.reader, err = rsc.segmentReader(rsc.offset) if err != nil { return 0, err } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 21.2K bytes - Click Count (0) -
internal/crypto/key_test.go
package crypto import ( "bytes" "crypto/rand" "encoding/hex" "io" "testing" "github.com/minio/minio/internal/logger" ) var shortRandom = func(limit int64) io.Reader { return io.LimitReader(rand.Reader, limit) } func recoverTest(i int, shouldPass bool, t *testing.T) { if err := recover(); err == nil && !shouldPass { t.Errorf("Test %d should fail but passed successfully", i)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jul 12 20:51:54 GMT 2024 - 6.7K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java
*/ Model read(File input, Map<String, ?> options) throws IOException, ModelParseException; /** * Reads the model from the specified character reader. The reader will be automatically closed before the method * returns. * * @param input The reader to deserialize the model from, must not be {@code null}. * @param options The options to use for deserialization, may be {@code null} to use the default values.Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 3.6K bytes - Click Count (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/util/TextUtilTest.java
return StringUtil.EMPTY; } try (final Reader reader = new StringReader(str)) { return normalizeText(reader, initialCapacity, maxAlphanumTermSize, maxSymbolTermSize, removeDuplication); } catch (final IOException e) { return StringUtil.EMPTY; } } public static String normalizeText(final Reader reader, final int initialCapacity, final int maxAlphanumTermSize,Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Aug 07 02:55:08 GMT 2025 - 8.2K bytes - Click Count (0) -
compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptorBuilder.java
} public interface ReaderSupplier { Reader open() throws IOException; } /** * @deprecated use {@link #build(ReaderSupplier)} */ @Deprecated public PluginDescriptor build(Reader reader) throws PlexusConfigurationException { return build(reader, null); } /** * @deprecated use {@link #build(ReaderSupplier, String)} */Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Mar 25 09:45:07 GMT 2025 - 17.5K bytes - Click Count (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/classanalysis/AnalyzeAndShade.kt
"" } val reader = ClassReader(Files.newInputStream(file)) val details = classes[reader.className] details.visited = true val classWriter = ClassWriter(0) reader.accept( ClassRemapper( classWriter,Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Sat Mar 22 03:48:38 GMT 2025 - 7.3K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java
@Override String read(ByteSource byteSource, Charset cs) throws IOException { StringBuilder sb = new StringBuilder(); try (InputStreamReader reader = new InputStreamReader(byteSource.openStream(), cs)) { CharStreams.copy(reader, sb); } return sb.toString(); } }, // It really seems like this should be faster than TO_BYTE_ARRAY_NEW_STRING. But it just isn'tCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 5.2K bytes - Click Count (0) -
internal/http/request-recorder.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package http import ( "bytes" "io" ) // RequestRecorder - records the // of a given io.Reader type RequestRecorder struct { // Data source to record io.Reader // Response body should be logged LogBody bool // internal recording buffer buf bytes.Buffer // total bytes read including header size bytesRead int }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 12 21:37:19 GMT 2023 - 1.8K bytes - Click Count (0) -
src/test/java/org/codelibs/core/io/CopyUtilTest.java
static String urlString = "あいうえお"; InputStream is = new ByteArrayInputStream(srcBytes); ByteArrayOutputStream os = new ByteArrayOutputStream(); Reader reader = new StringReader(srcString); StringWriter writer = new StringWriter(); StringBuilder builder = new StringBuilder(); URL url = ResourceUtil.getResource(getClass().getName().replace('.', '/') + ".txt");Created: Sat Dec 20 08:55:33 GMT 2025 - Last Modified: Sat May 10 01:32:17 GMT 2025 - 4.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/DocumentHelper.java
if (title == null) { return StringUtil.EMPTY; // empty } final int[] spaceChars = getSpaceChars(); try (final Reader reader = new StringReader(title)) { return TextUtil.normalizeText(reader).initialCapacity(title.length()).spaceChars(spaceChars).execute(); } catch (final IOException e) { return StringUtil.EMPTY; // empty } }
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 17.4K bytes - Click Count (0)