Search Options

Display Count
Sort
Preferred Language
Advanced Search

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.

  1. 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)
  2. 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")
    @Singleton
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Jun 07 06:22:47 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top