Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 2,099 for writeFn (0.05 seconds)

  1. 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)
  2. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/LoggingOutputStream.java

     * Side Public License, v 1.
     */
    
    package org.elasticsearch.gradle.internal;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.util.Arrays;
    
    /**
     * Writes data passed to this stream as log messages.
     *
     * The stream will be flushed whenever a newline is detected.
     * Allows setting an optional prefix before each line of output.
     */
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 2.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/io/CharSourceTest.java

        assertFalse(source.wasStreamClosed());
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertTrue(source.wasStreamClosed());
        assertThat(writer.toString()).isEqualTo(STRING);
      }
    
      public void testLines() throws IOException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  4. cmd/bitrot-whole.go

    }
    
    func (b *wholeBitrotWriter) Write(p []byte) (int, error) {
    	err := b.disk.AppendFile(context.TODO(), b.volume, b.filePath, p)
    	if err != nil {
    		return 0, err
    	}
    	_, err = b.Hash.Write(p)
    	if err != nil {
    		return 0, err
    	}
    	return len(p), nil
    }
    
    func (b *wholeBitrotWriter) Close() error {
    	return nil
    }
    
    // Returns whole-file bitrot writer.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  5. src/main/java/jcifs/internal/smb2/rdma/Smb2RdmaTransform.java

     * You should have received a copy of the GNU Lesser General Public
     * License along with this library; if not, write to the Free Software
     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.internal.smb2.rdma;
    
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB2 RDMA Transform structure for READ/WRITE channel info.
     *
     * As per MS-SMB2 2.2.13.1.1 and 2.2.21.1.1
     */
    public class Smb2RdmaTransform {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 3K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

            }
        }
    
        /**
         * Exports elevate words to a CSV file.
         * CSV format: SuggestWord, Reading, Permissions, Labels, Boost
         *
         * @param writer the Writer to output CSV data to
         */
        public void exportCsv(final Writer writer) {
            final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper();
            final CsvConfig cfg = new CsvConfig(',', '"', '"');
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 18.3K bytes
    - Click Count (0)
  7. src/test/java/jcifs/internal/smb2/lock/Smb2LockRequestTest.java

                assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, 8, 24));
    
                // Verify total bytes written (structure + lock data)
                assertEquals(24 + 24, bytesWritten); // 24 for structure, 24 for lock
            }
    
            @Test
            @DisplayName("Should write request structure correctly with multiple locks")
            void testWriteBytesWireFormatMultipleLocks() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 25.3K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/app/web/base/FessAdminAction.java

         */
        protected abstract String getActionRole();
    
        /**
         * Writes data to the specified file path.
         *
         * @param path the file path to write to
         * @param data the data to write
         */
        protected void write(final String path, final byte[] data) {
            validateFilePath(path);
            LdiFileUtil.write(path, data);
        }
    
        /**
         * Validates the file path.
         *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 19 13:57:12 GMT 2026
    - 10.9K bytes
    - Click Count (0)
  9. okhttp/src/androidMain/baseline-prof.txt

    HSPLokhttp3/internal/http2/Hpack$Reader;->readInt(II)I
    HSPLokhttp3/internal/http2/Hpack$Writer;-><init>(IZLokio/Buffer;I)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->evictToRecoverBytes(I)I
    HSPLokhttp3/internal/http2/Hpack$Writer;->insertIntoDynamicTable(Lokhttp3/internal/http2/Header;)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->writeByteString(Lokio/ByteString;)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->writeHeaders(Ljava/util/List;)V
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Dec 30 23:28:56 GMT 2024
    - 127.9K bytes
    - Click Count (1)
  10. internal/bucket/bandwidth/monitor_gen.go

    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z Details) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "LimitInBytesPerSecond"
    	err = en.Append(0x82, 0xb5, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x49, 0x6e, 0x42, 0x79, 0x74, 0x65, 0x73, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
Back to Top