Browse Source

Transport buffer even when there is an error

V2Ray 10 years ago
parent
commit
194abb9d6c
1 changed files with 3 additions and 1 deletions
  1. 3 1
      net/transport.go

+ 3 - 1
net/transport.go

@@ -14,10 +14,12 @@ func ReaderToChan(stream chan<- []byte, reader io.Reader) error {
 	for {
 	for {
 		buffer := make([]byte, bufferSize)
 		buffer := make([]byte, bufferSize)
 		nBytes, err := reader.Read(buffer)
 		nBytes, err := reader.Read(buffer)
+    if nBytes > 0 {
+      stream <- buffer[:nBytes]
+    }
 		if err != nil {
 		if err != nil {
 			return err
 			return err
 		}
 		}
-		stream <- buffer[:nBytes]
 	}
 	}
 	return nil
 	return nil
 }
 }