fix transport

This commit is contained in:
ginuerzh
2022-08-31 20:18:52 +08:00
parent be7af96d40
commit 470d229c58
3 changed files with 5 additions and 11 deletions

View File

@ -9,7 +9,7 @@ import (
)
func Transport(rw1, rw2 io.ReadWriter) error {
errc := make(chan error, 2)
errc := make(chan error, 1)
go func() {
errc <- copyBuffer(rw1, rw2)
}()
@ -18,16 +18,10 @@ func Transport(rw1, rw2 io.ReadWriter) error {
errc <- copyBuffer(rw2, rw1)
}()
err := <-errc
err2 := <-errc
if err != nil && err != io.EOF {
if err := <-errc; err != nil && err != io.EOF {
return err
}
if err2 != nil && err2 != io.EOF {
return err2
}
return nil
}