- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 608 for readLen (0.08 seconds)
-
internal/bucket/object/lock/lock.go
// Maximum 4KiB size per object lock config. const maxObjectLockConfigSize = 1 << 12 // ParseObjectLockConfig parses ObjectLockConfig from xml func ParseObjectLockConfig(reader io.Reader) (*Config, error) { config := Config{} if err := xml.NewDecoder(io.LimitReader(reader, maxObjectLockConfigSize)).Decode(&config); err != nil { return nil, err } return &config, nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.9K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/CharSinkTest.java
assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed()); assertEquals(STRING, sink.getString()); } public void testWriteFrom_reader() throws IOException { StringReader reader = new StringReader(STRING); sink.writeFrom(reader); assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed()); assertEquals(STRING, sink.getString()); }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 4.6K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/EncryptInvoker.java
import org.apache.maven.cling.invoker.LookupContext; import org.apache.maven.cling.invoker.LookupInvoker; import org.apache.maven.cling.utils.CLIReportingUtils; import org.jline.reader.LineReaderBuilder; import org.jline.reader.UserInterruptException; import org.jline.terminal.Terminal; import org.jline.utils.AttributedStyle; import org.jline.utils.Colors; /** * mvnenc invoker implementation. */
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jun 11 13:14:09 GMT 2025 - 4.5K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/UpgradeInvoker.java
import org.apache.maven.cling.invoker.LookupContext; import org.apache.maven.cling.invoker.LookupInvoker; import org.apache.maven.cling.utils.CLIReportingUtils; import org.jline.reader.LineReaderBuilder; import org.jline.reader.UserInterruptException; import org.jline.terminal.Terminal; import org.jline.utils.AttributedStyle; import org.jline.utils.Colors; /** * mvnup invoker implementation. */
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jun 11 13:14:09 GMT 2025 - 4.4K bytes - Click Count (0) -
src/archive/tar/example_test.go
"io" "log" "os" ) func Example_minimal() { // Create and add some files to the archive. var buf bytes.Buffer tw := tar.NewWriter(&buf) var files = []struct { Name, Body string }{ {"readme.txt", "This archive contains some text files."}, {"gopher.txt", "Gopher names:\nGeorge\nGeoffrey\nGonzo"}, {"todo.txt", "Get animal handling license."}, } for _, file := range files { hdr := &tar.Header{
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Nov 16 16:54:08 GMT 2017 - 1.4K bytes - Click Count (0) -
src/archive/zip/testdata/zip64-2.zip
README This small file is in ZIP64 format....
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Sep 08 04:08:51 GMT 2014 - 266 bytes - Click Count (0) -
cmd/admin-bucket-handlers.go
return } data, err := io.ReadAll(r.Body) if err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL) return } reader := bytes.NewReader(data) zr, err := zip.NewReader(reader, int64(len(data))) if err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL) return } rpt := importMetaReport{ madmin.BucketMetaImportErrs{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 33.3K bytes - Click Count (0) -
cmd/dummy-data-generator_test.go
package cmd import ( "bytes" "errors" "fmt" "io" "testing" ) var alphabets = []byte("abcdefghijklmnopqrstuvwxyz0123456789") // DummyDataGen returns a reader that repeats the bytes in `alphabets` // upto the desired length. type DummyDataGen struct { b []byte idx, length int64 } // NewDummyDataGen returns a ReadSeeker over the first `totalLength`
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
internal val reader: Http2Reader, ) : Http2Reader.Handler, () -> Unit { override fun invoke() { var connectionErrorCode = ErrorCode.INTERNAL_ERROR var streamErrorCode = ErrorCode.INTERNAL_ERROR var errorException: IOException? = null try { reader.readConnectionPreface(this) while (reader.nextFrame(false, this)) { }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 31.8K bytes - Click Count (0) -
internal/grid/msg_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package grid import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *Flags) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = Flags(zb0001) } return } // EncodeMsg implements msgp.Encodable
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 22.4K bytes - Click Count (0)