From 194abb9d6cb65c48dd367965508c59713ccac68c Mon Sep 17 00:00:00 2001 From: V2Ray Date: Mon, 14 Sep 2015 00:56:49 +0200 Subject: [PATCH] Transport buffer even when there is an error --- net/transport.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/net/transport.go b/net/transport.go index 5ed926966..caf93678b 100644 --- a/net/transport.go +++ b/net/transport.go @@ -14,10 +14,12 @@ func ReaderToChan(stream chan<- []byte, reader io.Reader) error { for { buffer := make([]byte, bufferSize) nBytes, err := reader.Read(buffer) + if nBytes > 0 { + stream <- buffer[:nBytes] + } if err != nil { return err } - stream <- buffer[:nBytes] } return nil }