- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 126 for reader_r (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
compat/maven-toolchain-builder/src/test/java/org/apache/maven/toolchain/merge/MavenToolchainMergerTest.java
import static org.junit.jupiter.api.Assertions.assertEquals; class MavenToolchainMergerTest { private MavenToolchainMerger merger = new MavenToolchainMerger(); private DefaultToolchainsReader reader = new DefaultToolchainsReader(); @Test void testMergeNulls() { merger.merge(null, null, null); PersistedToolchains pt = new PersistedToolchains(); merger.merge(pt, null, null);Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 6K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/builtin/BuiltinShellCommandRegistryFactory.java
import org.jline.console.CommandMethods; import org.jline.console.CommandRegistry; import org.jline.console.impl.JlineCommandRegistry; import org.jline.reader.Completer; import org.jline.reader.impl.completer.ArgumentCompleter; import org.jline.reader.impl.completer.StringsCompleter; import static java.util.Objects.requireNonNull; @Named("builtin") @SingletonCreated: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sat Jun 07 06:22:47 GMT 2025 - 12.3K bytes - Click Count (0) -
internal/etag/etag_test.go
}, } func TestReader(t *testing.T) { for i, test := range readerTests { reader := NewReader(t.Context(), strings.NewReader(test.Content), test.ETag, nil) if _, err := io.Copy(io.Discard, reader); err != nil { t.Fatalf("Test %d: read failed: %v", i, err) } if ETag := reader.ETag(); !Equal(ETag, test.ETag) { t.Fatalf("Test %d: ETag mismatch: got %q - want %q", i, ETag, test.ETag) } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 12.6K bytes - Click Count (0) -
src/main/java/jcifs/netbios/Lmhosts.java
*/ package jcifs.netbios; import java.io.BufferedReader; import java.io.File; import java.io.FileReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.Reader; import java.util.HashMap; import java.util.Map; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.CIFSContext; import jcifs.smb.SmbFileInputStream; /**
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6.3K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/RepositoryUtils.java
} public static WorkspaceRepository getWorkspace(RepositorySystemSession session) { WorkspaceReader reader = session.getWorkspaceReader(); return (reader != null) ? reader.getRepository() : null; } public static boolean repositoriesEquals(List<RemoteRepository> r1, List<RemoteRepository> r2) { if (r1.size() != r2.size()) {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Sep 04 18:33:16 GMT 2025 - 15.8K bytes - Click Count (0) -
cmd/erasure-encode_test.go
return nil, errFaultyDisk } func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error { return errFaultyDisk } func (badDisk) Hostname() string { return "" } const oneMiByte = 1 * humanize.MiByte var erasureEncodeTests = []struct { dataBlocks int
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.8K bytes - Click Count (0) -
cmd/bucket-handlers.go
apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, err) writeErrorResponse(ctx, w, apiErr, r.URL) return } const mapEntryOverhead = 200 var ( reader io.Reader actualSize int64 = -1 fileName string fanOutEntries = make([]minio.PutObjectFanOutEntry, 0, 100) ) maxParts := 1000 // Canonicalize the form values into http.Header.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 63.9K bytes - Click Count (0) -
build-tools-internal/src/integTest/groovy/org/elasticsearch/gradle/internal/test/rest/YamlRestCompatTestPluginFuncTest.groovy
def transformTask = ":yamlRestTestV${compatibleVersion}CompatTransform" def YAML_FACTORY = new YAMLFactory() def MAPPER = new ObjectMapper(YAML_FACTORY) def READER = MAPPER.readerFor(ObjectNode.class) def WRITER = MAPPER.writerFor(ObjectNode.class) def "yamlRestTestVxCompatTest does nothing when there are no tests"() { given:Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Thu Sep 30 16:30:48 GMT 2021 - 16.4K bytes - Click Count (0) -
cmd/storage-datatypes_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package cmd import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BaseOptions) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 151.7K bytes - Click Count (0) -
src/bufio/scan_test.go
} err := s.Err() if err != nil { t.Errorf("#%d: %v", n, err) } } } // slowReader is a reader that returns only a few bytes at a time, to test the incremental // reads in Scanner.Scan. type slowReader struct { max int buf io.Reader } func (sr *slowReader) Read(p []byte) (n int, err error) { if len(p) > sr.max { p = p[0:sr.max] } return sr.buf.Read(p)
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Click Count (0)