written - Code Search

compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/DefaultSettingsWriter.java

        Objects.requireNonNull(output, "output cannot be null");
        Objects.requireNonNull(settings, "settings cannot be null");

        try (Writer out = output) {
            new SettingsStaxWriter().write(out, settings.getDelegate());
        } catch (XMLStreamException e) {
            throw new IOException("Error writing settings", e);
        }

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Fri Oct 25 12:31:46 GMT 2024

- 2.8K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/io/CharSinkTest.java

  public void setUp() {
    sink = new TestCharSink();
  }

  public void testOpenBufferedStream() throws IOException {
    Writer writer = sink.openBufferedStream();
    assertTrue(sink.wasStreamOpened());
    assertFalse(sink.wasStreamClosed());

    writer.write(STRING);
    writer.close();

    assertTrue(sink.wasStreamClosed());
    assertThat(sink.getString()).isEqualTo(STRING);
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 4.7K bytes

- Click Count (0)

github.com/minio/minio

internal/grid/connection.go

		block := (<-chan struct{})(a)
		c.blockMessages.Store(&block)
		c.connMu.Unlock()
	}
}

// wsWriter writes websocket messages.
type wsWriter struct {
	tmp [ws.MaxHeaderSize]byte
}

// writeMessage writes a message to w without allocations.
func (ww *wsWriter) writeMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error {
	const fin = true
	var frame ws.Frame
	if s.ClientSide() {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 46.9K bytes

- Click Count (0)

github.com/codelibs/curl4j

src/main/java/org/codelibs/curl/CurlRequest.java

                    logger.fine(() -> ">>> " + body);
                    connection.setDoOutput(true);
                    try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(connection.getOutputStream(), encoding))) {
                        writer.write(body);
                        writer.flush();
                    }
                } else if (bodyStream != null) {
                    logger.fine(() -> ">>> <binary>");

Created: Thu Apr 02 15:34:12 GMT 2026

- Last Modified: Sat Mar 21 09:11:12 GMT 2026

- 19.7K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic-commons/code-quality-rules/src/main/resources/classycle/classycle_report_resources.zip

s,width=500,height=400"); list.document.close(); list.document.open(); list.document.write("<html><head><style type=\"text/css\">"); list.document.write("body { font-family:Helvetica,Arial,sans-serif; } "); list.document.write(".link { cursor:pointer;text-decoration:underline; } "); list.document.writeln("th { background-color:#aaaaaa; } </style></head><body>"); list.document.writeln(text); list.document.writeln("</body></html>"); list.document.close(); list.focus(); } //--> Analysis of Date: Summary...

Created: Wed Apr 01 11:36:16 GMT 2026

- Last Modified: Wed Dec 09 08:14:05 GMT 2020

- 23.4K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

            object : RequestBody() {
              override fun contentType(): MediaType? = null

              @Throws(
                IOException::class,
              )
              override fun writeTo(sink: BufferedSink) {
                for (i in 0..9) {
                  sink.writeByte(0)
                  sink.flush()
                  sleep(100)
                }

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Nov 04 19:13:52 GMT 2025

- 9.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/erasure-server-pool-rebalance_gen.go

func (z rebalanceInfo) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 3
	// write "startTs"
	err = en.Append(0x83, 0xa7, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x73)
	if err != nil {
		return
	}
	err = en.WriteTime(z.StartTime)
	if err != nil {
		err = msgp.WrapError(err, "StartTime")
		return
	}
	// write "stopTs"
	err = en.Append(0xa6, 0x73, 0x74, 0x6f, 0x70, 0x54, 0x73)

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 26.8K bytes

- Click Count (0)

github.com/minio/minio

internal/grid/msg_gen.go

}

// EncodeMsg implements msgp.Encodable
func (z *connectReq) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 4
	// write "ID"
	err = en.Append(0x84, 0xa2, 0x49, 0x44)
	if err != nil {
		return
	}
	err = en.WriteBytes((z.ID)[:])
	if err != nil {
		err = msgp.WrapError(err, "ID")
		return
	}
	// write "Host"
	err = en.Append(0xa4, 0x48, 0x6f, 0x73, 0x74)
	if err != nil {
		return

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 22.4K bytes

- Click Count (0)

github.com/elastic/elasticsearch

build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/release/TemplateUtils.java

        final StringWriter writer = new StringWriter();

        try {
            final SimpleTemplateEngine engine = new SimpleTemplateEngine();
            engine.createTemplate(template).make(bindings).writeTo(writer);
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        }

        return writer.toString().replace("\\r", "");
    }

Created: Wed Apr 08 16:19:15 GMT 2026

- Last Modified: Wed Sep 01 14:45:41 GMT 2021

- 1.3K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/io/BaseEncoding.java

   * {@code Writer}. When the returned {@code OutputStream} is closed, so is the backing {@code
   * Writer}.
   */
  @J2ktIncompatible
  @GwtIncompatible // Writer,OutputStream
  public abstract OutputStream encodingStream(Writer writer);

  /**
   * Returns a {@code ByteSink} that writes base-encoded bytes to the specified {@code CharSink}.
   */
  @J2ktIncompatible

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Mar 17 16:45:58 GMT 2026

- 41.6K bytes

- Click Count (0)

Search Options