diff --git a/tap/tlstapper/golang_reader.go b/tap/tlstapper/golang_reader.go index cd0a9b489..62a98d555 100644 --- a/tap/tlstapper/golang_reader.go +++ b/tap/tlstapper/golang_reader.go @@ -8,7 +8,6 @@ import ( ) type golangReader struct { - key string msgQueue chan []byte data []byte progress *api.ReadProgress @@ -55,15 +54,13 @@ func (r *golangReader) Read(p []byte) (int, error) { for len(r.data) == 0 { var ok bool - select { - case b, ok = <-r.msgQueue: - if !ok { - return 0, io.EOF - } - - r.data = b + b, ok = <-r.msgQueue + if !ok { + return 0, io.EOF } + r.data = b + if len(r.data) > 0 { break }