fix chan writer

8 years ago · 87a8f7a953
parent c884d04c7b
commit 87a8f7a953
1 changed files with 1 additions and 0 deletions
--- a/common/io/chain_writer.go
+++ b/common/io/chain_writer.go
@ -31,6 +31,7 @@ func (this *ChainWriter) Write(payload []byte) (int, error) {
 		if size > alloc.BufferSize {
 			buffer.Append(payload[:alloc.BufferSize])
 			size -= alloc.BufferSize
+			payload = payload[alloc.BufferSize:]
 		} else {
 			buffer.Append(payload)
 			size = 0