Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,189 for Reader (0.05 sec)

  1. cmd/dummy-data-generator_test.go

    	checkEq(readAll(r), readAll(NewDummyDataGen(100-int64(len(alphabets)), 0)))
    }
    
    // Compares all the bytes returned by the given readers. Any Read
    // errors cause a `false` result. A string describing the error is
    // also returned.
    func cmpReaders(r1, r2 io.Reader) (bool, string) {
    	bufLen := 32 * 1024
    	b1, b2 := make([]byte, bufLen), make([]byte, bufLen)
    	for i := 0; true; i++ {
    		n1, e1 := io.ReadFull(r1, b1)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance_gen.go

    func (z rebalanceMetrics) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 0
    	_ = z
    	err = en.Append(0x80)
    	if err != nil {
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z rebalanceMetrics) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 0
    	_ = z
    	o = append(o, 0x80)
    	return
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  3. src/bufio/scan.go

    // large to fit in the [Scanner.Buffer]. When a scan stops, the reader may have
    // advanced arbitrarily far past the last token. Programs that need more
    // control over error handling or large tokens, or must run sequential scans
    // on a reader, should use [bufio.Reader] instead.
    type Scanner struct {
    	r            io.Reader // The reader provided by the client.
    	split        SplitFunc // The function to split the tokens.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed May 21 18:05:26 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  4. src/archive/zip/register.go

    // A Decompressor returns a new decompressing reader, reading from r.
    // The [io.ReadCloser]'s Close method must be used to release associated resources.
    // The Decompressor itself must be safe to invoke from multiple goroutines
    // simultaneously, but each returned reader will be used only by
    // one goroutine at a time.
    type Decompressor func(r io.Reader) io.ReadCloser
    
    var flateWriterPool sync.Pool
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  5. cmd/bucket-stats_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BucketReplicationStat) 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--
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 57.5K bytes
    - Viewed (0)
  6. README.md

    // Index suggestions from existing Elasticsearch documents
    DocumentReader reader = new ESSourceReader(
        client,
        suggester.settings(),
        "content-index",        // source index
        "document"             // document type
    );
    
    suggester.indexer()
        .indexFromDocument(reader, 2, 100)  // threads=2, batch=100
        .getResponse();
    ```
    
    ### Index from Query Logs
    
    ```java
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Sun Aug 31 03:31:14 UTC 2025
    - 12.1K bytes
    - Viewed (1)
  7. src/main/java/jcifs/smb1/netbios/Lmhosts.java

    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileNotFoundException;
    import java.io.FileReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.Reader;
    import java.util.Hashtable;
    
    import jcifs.smb1.Config;
    import jcifs.smb1.smb1.SmbFileInputStream;
    import jcifs.smb1.util.LogStream;
    
    /**
     * Lmhosts file handling for NetBIOS name resolution.
     */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

                throw new SuggestIndexException("Failed to index from query_string.", e);
            }
        }
    
        /**
         * Indexes documents from a query log reader asynchronously.
         * @param queryLogReader The query log reader.
         * @param docPerReq The number of documents to process per request.
         * @param requestInterval The interval between requests.
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  9. docs/contribute/concurrency.md

    The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/core/collection/IndexedIterator.java

     * }
     * </pre>
     *
     * <pre>
     * import static org.codelibs.core.collection.IndexedIterator.*;
     * import static org.codelibs.core.io.LineIterator.*;
     *
     * BufferedReader reader = ...;
     * for (Indexed&lt;String&gt; indexed : indexed(iterable(reader))) {
     *     System.out.println(indexed.getIndex());
     *     System.out.println(indexed.getElement());
     * }
     * </pre>
     *
     * @author wyukawa
     * @param <T> the element type
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jun 19 09:12:22 UTC 2025
    - 3.3K bytes
    - Viewed (0)
Back to top