Flush - Code Search

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

      if (byteCount > length) writeContinuationFrames(streamId, byteCount - length)
    }
  }

  @Throws(IOException::class)
  fun flush() {
    withLock {
      if (closed) throw IOException("closed")
      sink.flush()
    }
  }

  @Throws(IOException::class)
  fun rstStream(
    streamId: Int,
    errorCode: ErrorCode,
  ) {
    withLock {

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Wed May 28 23:28:25 UTC 2025

- 11K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

      requestBody.flush()
      val responseBody = response.body.source()
      assertThat(responseBody.readUtf8Line())
        .isEqualTo("response B")
      requestBody.writeUtf8("request C\n")
      requestBody.flush()
      assertThat(responseBody.readUtf8Line())
        .isEqualTo("response D")
      requestBody.writeUtf8("request E\n")
      requestBody.flush()

Registered: Fri Dec 26 11:42:13 UTC 2025

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

- 25.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      "Trailers cannot be read because the state is $state"
    }
    return trailers
  }

  override fun flushRequest() {
    socket.sink.flush()
  }

  override fun finishRequest() {
    socket.sink.flush()
  }

  /** Returns bytes of a request header for sending on an HTTP transport. */
  fun writeRequest(
    headers: Headers,
    requestLine: String,
  ) {

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Thu Jul 31 04:18:40 UTC 2025

- 17.5K bytes

- Viewed (7)

github.com/codelibs/curl4j

src/test/java/org/codelibs/curl/io/ContentOutputStreamTest.java

        // flush() should work with in-memory data
        ContentOutputStream cos = new ContentOutputStream(10, Curl.tmpDir);
        cos.write(new byte[] { 0, 1, 2 });
        cos.flush();
        assertTrue(cos.isInMemory());
        cos.close();
    }

    @Test
    public void testFlushInFile() throws IOException {
        // flush() should work with file-based data

Registered: Sat Dec 20 09:13:53 UTC 2025

- Last Modified: Wed Nov 12 14:01:04 UTC 2025

- 9.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-replication-metrics_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeActiveWorkerStat(b *testing.B) {
	v := ActiveWorkerStat{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 17.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/data-usage-cache_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeallTierStats(b *testing.B) {
	v := allTierStats{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 19K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-replicate_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeBatchJobReplicateCredentials(b *testing.B) {
	v := BatchJobReplicateCredentials{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 14.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-replication-utils_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeBucketReplicationResyncStatus(b *testing.B) {
	v := BucketReplicationResyncStatus{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 23K bytes

- Viewed (0)

github.com/minio/minio

cmd/site-replication-metrics_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeRStat(b *testing.B) {
	v := RStat{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 12.9K bytes

- Viewed (0)

github.com/minio/minio

internal/grid/msg_gen_test.go

	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	en := msgp.NewWriter(msgp.Nowhere)
	b.ReportAllocs()
	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		v.EncodeMsg(en)
	}
	en.Flush()
}

func BenchmarkDecodeconnectReq(b *testing.B) {
	v := connectReq{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)
	b.SetBytes(int64(buf.Len()))
	rd := msgp.NewEndlessReader(buf.Bytes(), b)

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 12.9K bytes

- Viewed (0)

Search Options