diff options
| author |  Runxi Yu | 2026-03-28 20:07:11 +0000 |
|---|---|---|
| committer | Runxi Yu | 2026-03-28 20:07:11 +0000 |
| commit | 791b4039e4407c92e267cac3031cf1e8999b5013 (patch) | |
| tree | 77d063a86ea7c86ed40ca97d1b8d310ca85db2a4 /network/protocol/sideband64k | |
| parent | network: Rename flush (clearly distinguish flushing IO and writing flush pack... (diff) | |
| signature | No signature | |
network/protocol: Flush ChunkWriter properly v0.1.129
Diffstat (limited to 'network/protocol/sideband64k')
| -rw-r--r-- | network/protocol/sideband64k/chunk_writer.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/network/protocol/sideband64k/chunk_writer.go b/network/protocol/sideband64k/chunk_writer.go index f95f75d8..9ee4e9f8 100644 --- a/network/protocol/sideband64k/chunk_writer.go +++ b/network/protocol/sideband64k/chunk_writer.go @@ -62,3 +62,8 @@ func (cw *ChunkWriter) ReadFrom(r io.Reader) (int64, error) { } } } + +// Flush flushes buffered output in the underlying transport. +func (cw *ChunkWriter) Flush() error { + return cw.enc.Flush() +} |