Writer - Code Search

cmd/metacache-entries_test.go

	if !reflect.DeepEqual(want, got) {

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Sun Jan 02 17:15:06 GMT 2022

- 31.6K bytes

- Viewed (0)

github.com/google/guava

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());
    assertEquals(STRING, writer.toString());
  }

  public void testLines() throws IOException {

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 13K bytes

- Viewed (0)

github.com/google/guava

android/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());
    assertEquals(STRING, writer.toString());
  }

  public void testCopyTo_appendable() throws IOException {

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 12K bytes

- Viewed (0)

github.com/minio/minio

cmd/local-locker_gen.go

		return
	}
	err = en.WriteBool(z.Writer)
	if err != nil {
		err = msgp.WrapError(err, "Writer")
		return
	}
	// write "UID"
	err = en.Append(0xa3, 0x55, 0x49, 0x44)
	if err != nil {
		return
	}
	err = en.WriteString(z.UID)
	if err != nil {
		err = msgp.WrapError(err, "UID")
		return
	}
	// write "Timestamp"
	err = en.Append(0xa9, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70)
	if err != nil {

Go

- Registered: Sun Apr 28 19:28:10 GMT 2024

- Last Modified: Thu Mar 21 17:21:35 GMT 2024

- 13.8K bytes

- Viewed (0)

github.com/google/guava

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

    public CharSink createSink() throws IOException {
      File file = createFile();
      if (initialString != null) {
        Writer writer = new OutputStreamWriter(new FileOutputStream(file), Charsets.UTF_8);
        try {
          writer.write(initialString);
        } finally {
          writer.close();
        }
        return Files.asCharSink(file, Charsets.UTF_8, FileWriteMode.APPEND);
      }

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Thu Sep 09 17:57:59 GMT 2021

- 17.9K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/SourceSinkFactories.java

    public CharSink createSink() throws IOException {
      File file = createFile();
      if (initialString != null) {
        Writer writer = new OutputStreamWriter(new FileOutputStream(file), Charsets.UTF_8);
        try {
          writer.write(initialString);
        } finally {
          writer.close();
        }
        return Files.asCharSink(file, Charsets.UTF_8, FileWriteMode.APPEND);
      }

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Thu Apr 06 12:56:11 GMT 2023

- 12.7K bytes

- Viewed (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>");

Java

- Registered: Thu May 02 15:34:13 GMT 2024

- Last Modified: Sun Feb 12 12:21:25 GMT 2023

- 12.3K bytes

- Viewed (0)

github.com/golang/go

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 {

Go

- Registered: Tue Apr 30 11:13:12 GMT 2024

- Last Modified: Wed Mar 27 18:23:49 GMT 2024

- 19.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

    val newMaxFrameSize = 16777215
    val writer = Http2Writer(Buffer(), true)
    writer.applyAndAckSettings(Settings().set(Settings.MAX_FRAME_SIZE, newMaxFrameSize))
    assertThat(writer.maxDataLength()).isEqualTo(newMaxFrameSize)
    writer.frameHeader(0, newMaxFrameSize, Http2.TYPE_DATA, FLAG_NONE)
  }

  @Test fun streamIdHasReservedBit() {
    val writer = Http2Writer(Buffer(), true)

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 28.1K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/select.go

}

func (s3Select *S3Select) marshal(buf *bytes.Buffer, record sql.Record) error {
	switch s3Select.Output.format {
	case csvFormat:
		// Use bufio Writer to prevent csv.Writer from allocating a new buffer.
		bufioWriter := bufioWriterPool.Get().(*bufio.Writer)
		defer func() {
			bufioWriter.Reset(xioutil.Discard)
			bufioWriterPool.Put(bufioWriter)
		}()

		bufioWriter.Reset(buf)
		opts := sql.WriteCSVOpts{

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Mon Nov 06 22:26:08 GMT 2023

- 21K bytes

- Viewed (0)

Search Options