Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 2,024 for writer (0.07 seconds)

  1. cmd/metacache-stream.go

    		}
    		return nil
    	}
    	return &w
    }
    
    // write one or more objects to the stream in order.
    // It is favorable to send as many objects as possible in a single write,
    // but no more than math.MaxUint32
    func (w *metacacheWriter) write(objs ...metaCacheEntry) error {
    	if w == nil {
    		return errors.New("metacacheWriter: nil writer")
    	}
    	if len(objs) == 0 {
    		return nil
    	}
    	if w.creator != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  2. internal/ioutil/ioutil.go

    			// we have written the entire stream, return right here.
    			return written, nil
    		}
    
    		if eof {
    			// We reached EOF prematurely but we did not write everything
    			// that we promised that we would write.
    			if totalSize > 0 && written != totalSize {
    				return written, io.ErrUnexpectedEOF
    			}
    			return written, nil
    		}
    	}
    }
    
    // SafeClose safely closes any channel of any type
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/dict/stopwords/StopwordsFile.java

             */
            public StopwordsItem write(final StopwordsItem oldItem) {
                try {
                    if (item == null || item.getId() != oldItem.getId() || !item.isUpdated()) {
                        writer.write(oldItem.toLineString());
                        writer.write(Constants.LINE_SEPARATOR);
                        return oldItem;
                    }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 07:09:00 GMT 2025
    - 13K bytes
    - Click Count (0)
  4. clause/clause.go

    // ClauseBuilder clause builder, allows to customize how to build clause
    type ClauseBuilder func(Clause, Builder)
    
    type Writer interface {
    	WriteByte(byte) error
    	WriteString(string) (int, error)
    }
    
    // Builder builder interface
    type Builder interface {
    	Writer
    	WriteQuoted(field interface{})
    	AddVar(Writer, ...interface{})
    	AddError(error) error
    }
    
    // Clause
    type Clause struct {
    	Name                string // WHERE
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 1.8K bytes
    - Click Count (0)
  5. src/test/java/jcifs/smb/SmbCopyUtilTest.java

                    w.wait(10);
                }
                assertTrue(w.isReady(), "WriterThread should be ready");
    
                // Submit a write that will throw inside the writer thread
                w.write(payload, payload.length, out);
    
                // Give the writer thread time to process and set exception
                w.wait(100);
            }
    
            // Wait a bit more to ensure exception is captured
            Thread.sleep(100);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  6. internal/s3select/csv/record.go

    	return other
    }
    
    // WriteCSV - encodes to CSV data.
    func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error {
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    	w.AlwaysQuote = opts.AlwaysQuote
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    	if err := w.Write(r.csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.Error()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  7. build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/precommit/LicenseHeadersTask.java

            }
        }
    
        private ClaimStatistic toXmlReportFile(ReportConfiguration config, Writer writer) throws RatException, IOException {
            ClaimStatistic stats = new ClaimStatistic();
            RatReport standardReport = XmlReportFactory.createStandardReport(new XmlWriter(writer), stats, config);
    
            standardReport.startReport();
            for (FileCollection dirSet : getSourceFolders().get()) {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Sep 09 18:53:35 GMT 2021
    - 10.6K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/dict/stemmeroverride/StemmerOverrideFile.java

             */
            public StemmerOverrideItem write(final StemmerOverrideItem oldItem) {
                try {
                    if (item == null || item.getId() != oldItem.getId() || !item.isUpdated()) {
                        writer.write(oldItem.toLineString());
                        writer.write(Constants.LINE_SEPARATOR);
                        return oldItem;
                    }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Dec 20 05:56:45 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java

                    throw new DictionaryException("Failed to write: " + oldItem + " -> " + item, e);
                }
            }
    
            /**
             * Writes a line to the new file.
             *
             * @param line The line to write.
             */
            public void write(final String line) {
                try {
                    writer.write(line);
                    writer.write(Constants.LINE_SEPARATOR);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 07:09:00 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  10. src/archive/zip/zip_test.go

    	}
    	for i := 0; i < chunks; i++ {
    		_, err := f.Write(chunk)
    		if err != nil {
    			t.Fatal("write chunk:", err)
    		}
    	}
    	if frag := int(size % chunkSize); frag > 0 {
    		_, err := f.Write(chunk[:frag])
    		if err != nil {
    			t.Fatal("write chunk:", err)
    		}
    	}
    	end := []byte("END\n")
    	_, err = f.Write(end)
    	if err != nil {
    		t.Fatal("write end:", err)
    	}
    	if err := w.Close(); err != nil {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu May 23 01:00:11 GMT 2024
    - 19.6K bytes
    - Click Count (0)
Back to Top