Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 405 for _writers (0.08 sec)

  1. src/bufio/bufio.go

    // accepted and all subsequent writes, and [Writer.Flush], will return the error.
    // After all data has been written, the client should call the
    // [Writer.Flush] method to guarantee all data has been forwarded to
    // the underlying [io.Writer].
    type Writer struct {
    	err error
    	buf []byte
    	n   int
    	wr  io.Writer
    }
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Sep 03 14:04:47 UTC 2025
    - 22K bytes
    - Viewed (0)
  2. cmd/bitrot.go

    func closeBitrotReaders(rs []io.ReaderAt) {
    	for _, r := range rs {
    		if r != nil {
    			if br, ok := r.(io.Closer); ok {
    				br.Close()
    			}
    		}
    	}
    }
    
    // Close all the writers.
    func closeBitrotWriters(ws []io.Writer) []error {
    	errs := make([]error, len(ws))
    	for i, w := range ws {
    		if w == nil {
    			errs[i] = errDiskNotFound
    			continue
    		}
    		if bw, ok := w.(io.Closer); ok {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 26 19:26:13 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/dict/stemmeroverride/StemmerOverrideFile.java

            protected boolean isCommit = false;
    
            /** The temporary file to write changes to. */
            protected File newFile;
    
            /** The writer for the temporary file. */
            protected Writer writer;
    
            /** The stemmer override item being added or updated. */
            protected StemmerOverrideItem item;
    
            /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt

        }
    
        return result
      }
    
      override fun toDer(
        writer: DerWriter,
        value: T,
      ) {
        if (typeHint) {
          writer.typeHint = value
        }
    
        if (isOptional && value == defaultValue) {
          // Nothing to write!
          return
        }
    
        writer.write(name, tagClass, tag) {
          codec.encode(writer, value)
        }
      }
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/dict/protwords/ProtwordsFile.java

            protected boolean isCommit = false;
    
            /** Temporary file for storing updates */
            protected File newFile;
    
            /** Writer for writing to the temporary file */
            protected Writer writer;
    
            /** The item being updated */
            protected ProtwordsItem item;
    
            /**
             * Constructor for ProtwordsUpdater.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/io/CharStreams.java

      }
    
      /**
       * Returns a {@link Writer} that simply discards written chars.
       *
       * <p><b>Java 11+ users:</b> use {@link Writer#nullWriter()} instead. Note that the {@link
       * CharStreams} method returns a singleton writer whose {@code close} method has no effect, while
       * the {@link Writer#nullWriter()} method returns a new instance whose methods throw after the
       * instance is {@link Writer#close() closed}.
       *
       * @since 15.0
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 30 17:25:01 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

            protected boolean isCommit = false;
    
            /** The temporary file to write changes to. */
            protected File newFile;
    
            /** The writer for the temporary file. */
            protected Writer writer;
    
            /** The synonym item being added or updated. */
            protected SynonymItem item;
    
            /**
             * Constructs a new updater for a synonym item.
             *
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java

            /** True if the changes have been committed. */
            protected boolean isCommit = false;
    
            /** The new file. */
            protected File newFile;
    
            /** The writer for the new file. */
            protected Writer writer;
    
            /** The item to be added or updated. */
            protected KuromojiItem item;
    
            /**
             * Constructs a new Kuromoji updater.
             *
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/util/ThreadDumpUtil.java

            processThreadDump(logger::error);
        }
    
        /**
         * Writes thread dump information to the specified file.
         *
         * @param file the file path to write the thread dump to
         */
        public static void writeThreadDump(final String file) {
            try (final Writer writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file), Constants.CHARSET_UTF_8))) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  10. src/archive/zip/zip_test.go

    		t.Skip("too slow on wasm")
    	}
    	if testing.Short() {
    		t.Skip("skipping in short mode")
    	}
    	t.Parallel()
    	// gen returns a func that writes a zip with a wantLen bytes
    	// of central directory.
    	gen := func(wantLen int64) func(*Writer) {
    		return func(w *Writer) {
    			w.testHookCloseSizeOffset = func(size, off uint64) {
    				if size != uint64(wantLen) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
Back to top