Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 212 for newReader (0.1 sec)

  1. cmd/config-common.go

    		return errConfigNotFound
    	}
    	return err
    }
    
    func saveConfigWithOpts(ctx context.Context, store objectIO, configFile string, data []byte, opts ObjectOptions) error {
    	hashReader, err := hash.NewReader(ctx, bytes.NewReader(data), int64(len(data)), "", getSHA256Hash(data), int64(len(data)))
    	if err != nil {
    		return err
    	}
    
    	_, err = store.PutObject(ctx, minioMetaBucket, configFile, NewPutObjReader(hashReader), opts)
    	return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  2. src/bytes/reader.go

    		err = io.ErrShortWrite
    	}
    	return
    }
    
    // Reset resets the [Reader] to be reading from b.
    func (r *Reader) Reset(b []byte) { *r = Reader{b, 0, -1} }
    
    // NewReader returns a new [Reader] reading from b.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/lex/lex_test.go

    			"A",
    			"B(THIS)",
    		),
    		"x.\n",
    	},
    	*/
    }
    
    func TestLex(t *testing.T) {
    	for _, test := range lexTests {
    		input := NewInput(test.name)
    		input.Push(NewTokenizer(test.name, strings.NewReader(test.input), nil))
    		result := drain(input)
    		if result != test.output {
    			t.Errorf("%s: got %q expected %q", test.name, result, test.output)
    		}
    	}
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  4. src/archive/tar/example_test.go

    		if _, err := tw.Write([]byte(file.Body)); err != nil {
    			log.Fatal(err)
    		}
    	}
    	if err := tw.Close(); err != nil {
    		log.Fatal(err)
    	}
    
    	// Open and iterate through the files in the archive.
    	tr := tar.NewReader(&buf)
    	for {
    		hdr, err := tr.Next()
    		if err == io.EOF {
    			break // End of archive
    		}
    		if err != nil {
    			log.Fatal(err)
    		}
    		fmt.Printf("Contents of %s:\n", hdr.Name)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 16 16:54:08 UTC 2017
    - 1.4K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_test.go

    	f, err := os.Open("testdata/xl.meta-corrupt.gz")
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer f.Close()
    
    	gz, err := gzip.NewReader(bufio.NewReader(f))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	buf, err := io.ReadAll(gz)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	_, err = readXLMetaNoData(bytes.NewReader(buf), int64(len(buf)))
    	if err == nil {
    		t.Fatal("expected error but returned success")
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  6. internal/s3select/simdj/reader.go

    				err = fmt.Errorf("unexpected root json type:%v", typ)
    				r.err = &err
    				return
    			}
    		}
    		if in.Error == io.EOF {
    			return
    		}
    	}
    }
    
    // NewReader - creates new JSON reader using readCloser.
    func NewReader(readCloser io.ReadCloser, args *json.ReaderArgs) *Reader {
    	r := Reader{
    		args:       args,
    		readCloser: &safeCloser{r: io.Reader(readCloser)},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/io/CharSinkTest.java

          assertThrows(IOException.class, () -> failSource.copyTo(okSink));
          // ensure writer was closed IF it was opened (depends on implementation whether or not it's
          // opened at all if source.newReader() throws).
          assertTrue(
              "stream not closed when copying from source with option: " + option,
              !okSink.wasStreamOpened() || okSink.wasStreamClosed());
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. cmd/object-handlers-common_test.go

    			expectedCode:    304,
    		},
    	}
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			recorder := httptest.NewRecorder()
    			request := httptest.NewRequest(http.MethodHead, "/bucket/a", bytes.NewReader([]byte{}))
    			request.Header.Set(xhttp.IfNoneMatch, tc.ifNoneMatch)
    			request.Header.Set(xhttp.IfModifiedSince, tc.ifModifiedSince)
    			request.Header.Set(xhttp.IfMatch, tc.ifMatch)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  9. internal/s3select/simdj/reader_amd64_test.go

    	"github.com/minio/simdjson-go"
    )
    
    type tester interface {
    	Fatal(args ...interface{})
    }
    
    func loadCompressed(t tester, file string) (js []byte) {
    	dec, err := zstd.NewReader(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer dec.Close()
    	js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	js, err = dec.DecodeAll(js, nil)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  10. docs/debugging/inspect/export.go

    		case 0:
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(b))
    			if e != nil {
    				return nil, e
    			}
    		case 1, 2:
    			v, b, e := msgp.ReadBytesZC(b)
    			if e != nil {
    				return nil, e
    			}
    			if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil {
    				// Read metadata CRC (added in v2, ignore if not found)
    				b = nbuf
    			}
    
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(v))
    			if e != nil {
    				return nil, e
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 08 15:58:02 UTC 2022
    - 9.1K bytes
    - Viewed (0)
Back to top