Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 435 for Writer (0.04 seconds)

  1. internal/s3select/select.go

    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = bpool.Pool[*bufio.Writer]{
    	New: func() *bufio.Writer {
    		// io.Discard is just used to create the writer. Actual destination
    		// writer is set later by Reset() before using it.
    		return bufio.NewWriter(xioutil.Discard)
    	},
    }
    
    // UnmarshalXML - decodes XML data.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  2. build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/codegen/PluginIdExtensionsFacade.kt

    ) {
        file.bufferedWriter().use { writer ->
            writer.appendReproducibleNewLine(fileHeader)
            pluginIdExtensionDeclarationsFor(
                gradleJars,
                pluginDependenciesSpecQualifiedName,
                pluginDependencySpecQualifiedName
            ).forEach { extension ->
                writer.write("\n")
                writer.appendReproducibleNewLine(extension)
            }
        }
    }
    
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri Jun 28 08:29:28 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  3. internal/ioutil/ioutil_test.go

    	}
    	writer.Write(nil)
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    	}
    
    	writer = WriteOnClose(io.Discard)
    	writer.Close()
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    	}
    }
    
    // Test for AppendFile.
    func TestAppendFile(t *testing.T) {
    	f, err := os.CreateTemp(t.TempDir(), "")
    	if err != nil {
    		t.Fatal(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  4. internal/ioutil/discard.go

    // implementation which is buggy on NUMA systems, we have to use a simpler
    // io.Writer implementation alone avoids also unnecessary buffer copies,
    // and as such incurred latencies.
    var Discard io.Writer = discard{}
    
    // discard is /dev/null for Golang.
    type discard struct{}
    
    func (discard) Write(p []byte) (int, error) {
    	return len(p), nil
    }
    
    // DiscardReader discarded reader
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 1.3K bytes
    - Click Count (0)
  5. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/DefaultModelWriter.java

            Objects.requireNonNull(output, "output cannot be null");
            Objects.requireNonNull(model, "model cannot be null");
    
            try (Writer out = output) {
                new MavenXpp3Writer().write(out, model);
            }
        }
    
        @Override
        public void write(OutputStream output, Map<String, Object> options, Model model) throws IOException {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jan 10 07:09:12 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/InteractiveGoalSupport.java

            if (!context.interactive) {
                context.terminal.writer().println("This tool works only in interactive mode!");
                context.terminal
                        .writer()
                        .println("Tool purpose is to configure password management on developer workstations.");
                context.terminal
                        .writer()
                        .println(
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Dec 11 09:13:06 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  7. logger/logger.go

    const (
    	// Silent silent log level
    	Silent LogLevel = iota + 1
    	// Error error log level
    	Error
    	// Warn warn log level
    	Warn
    	// Info info log level
    	Info
    )
    
    // Writer log writer interface
    type Writer interface {
    	Printf(string, ...interface{})
    }
    
    // Config logger config
    type Config struct {
    	SlowThreshold             time.Duration
    	Colorful                  bool
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Jan 12 10:19:28 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  8. cmd/bitrot-streaming.go

    // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation.
    // The output is written to the supplied writer w.
    func newStreamingBitrotWriterBuffer(w io.Writer, algo BitrotAlgorithm, shardSize int64) io.Writer {
    	return &streamingBitrotWriter{iow: ioutil.NopCloser(w), h: algo.New(), shardSize: shardSize, canClose: nil, closeWithErr: func(err error) {}}
    }
    
    // Returns streaming bitrot writer implementation.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 17 19:19:30 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  9. 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)
        }
      }
    
      /**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/internal/extension/model/io/xpp3/CoreExtensionsXpp3Writer.java

            this.fileComment = fileComment;
        } // -- void setFileComment( String )
    
        /**
         * Method write.
         *
         * @param writer a writer object.
         * @param coreExtensions a coreExtensions object.
         * @throws IOException IOException if any.
         */
        public void write(Writer writer, CoreExtensions coreExtensions) throws IOException {
            XmlSerializer serializer = new MXSerializer();
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Oct 27 13:24:03 GMT 2025
    - 6.7K bytes
    - Click Count (0)
Back to Top