- Sort Score
- Result 10 results
- Languages All
Results 201 - 208 of 208 for newReader (0.08 sec)
-
cmd/xl-storage.go
// fdatasync() at the end instead of opening the file with O_DSYNC. // // This is an optimization mainly to ensure faster I/O. if len(b) > xioutil.DirectioAlignSize { r := bytes.NewReader(b) return s.writeAllDirect(ctx, filePath, r.Size(), r, flags, skipParent, true) } w, err = s.openFileSync(filePath, flags, skipParent) } else { w, err = s.openFile(filePath, flags, skipParent) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 91.3K bytes - Viewed (0) -
api/go1.txt
pkg archive/tar, const TypeRegA ideal-char pkg archive/tar, const TypeSymlink ideal-char pkg archive/tar, const TypeXGlobalHeader ideal-char pkg archive/tar, const TypeXHeader ideal-char pkg archive/tar, func NewReader(io.Reader) *Reader pkg archive/tar, func NewWriter(io.Writer) *Writer pkg archive/tar, method (*Reader) Next() (*Header, error) pkg archive/tar, method (*Reader) Read([]uint8) (int, error)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Aug 14 18:58:28 UTC 2013 - 1.7M bytes - Viewed (0) -
internal/s3select/json/preader_test.go
t.Fatal(err) } for _, file := range files { t.Run(file.Name(), func(t *testing.T) { f, err := os.Open(filepath.Join("testdata", file.Name())) if err != nil { t.Fatal(err) } r := NewPReader(f, &ReaderArgs{}) var record sql.Record for { record, err = r.Read(record) if err != nil { break } } r.Close() if err != io.EOF {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 2.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/CurrentDateHeader.java
@Override public Response intercept(Chain chain) throws IOException { Request request = chain.request(); Headers newHeaders = request.headers() .newBuilder() .add("Date", new Date()) .build(); Request newRequest = request.newBuilder() .headers(newHeaders) .build(); return chain.proceed(newRequest); } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Oct 31 15:32:50 UTC 2018 - 1.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/LinkedHashMultimap.java
this.nextInValueBucket = nextInValueBucket; } @SuppressWarnings("nullness") // see the comment on the class fields, especially about newHeader static <K extends @Nullable Object, V extends @Nullable Object> ValueEntry<K, V> newHeader() { return new ValueEntry<>(null, null, 0, null); } boolean matchesValue(@CheckForNull Object v, int smearedVHash) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 24.3K bytes - Viewed (0) -
internal/s3select/json/preader.go
r.bufferPool.Put(in.input) in.input = nil in.err = d.Err() in.dst <- all } }() } } // NewPReader - creates new parallel JSON reader using readCloser. // Should only be used for LINES types. func NewPReader(readCloser io.ReadCloser, args *ReaderArgs) *PReader { r := &PReader{ args: args, buf: bufio.NewReaderSize(readCloser, jsonSplitSize*2),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
} public void testDecoupledLoader() { FinalizableReferenceQueue.DecoupledLoader decoupledLoader = new FinalizableReferenceQueue.DecoupledLoader() { @Override URLClassLoader newLoader(URL base) { return new DecoupledClassLoader(new URL[] {base}); } }; Class<?> finalizerCopy = decoupledLoader.loadFinalizer(); assertNotNull(finalizerCopy);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 4.8K bytes - Viewed (0) -
guava/src/com/google/common/base/FinalizableReferenceQueue.java
* Finalizer.class -> CustomClassLoader -> CustomClassLoader.class -> This class loader * * System class loader will (and must) be the parent. */ try (URLClassLoader finalizerLoader = newLoader(getBaseUrl())) { return finalizerLoader.loadClass(FINALIZER_CLASS_NAME); } catch (Exception e) { logger.log(Level.WARNING, LOADING_ERROR, e); return null; } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Jul 11 20:51:36 UTC 2024 - 13.1K bytes - Viewed (0)