Skip to content

Commit 511dbcf

Browse files
authored
Fix mux
1 parent ea5a53c commit 511dbcf

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

common/buf/copy.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package buf
22

33
import (
4+
"fmt"
45
"io"
56
"sync"
67
"time"
@@ -137,13 +138,20 @@ func CopyOnceTimeout(reader Reader, writer Writer, timeout time.Duration) error
137138
}
138139

139140
func TryCopyV(reader Reader, writer Writer, options ...CopyOption) error {
141+
// too bad section, many type assertions
142+
if _, ok := writer.(*BufferToBytesWriter); !ok {
143+
return Copy(reader, writer, options...)
144+
}
140145
var doCopyV bool
141146
if tr, ok := reader.(*TimeoutWrapperReader); ok {
147+
fmt.Printf("treader internal type: %T\n", reader)
142148
if _, ok := tr.Reader.(*SingleReader); ok {
149+
fmt.Printf("tsreader internal type: %T\n", tr.Reader)
143150
doCopyV = true
144151
}
145152
}
146-
if _, ok := reader.(*SingleReader); ok {
153+
if sr, ok := reader.(*SingleReader); ok {
154+
fmt.Printf("sreader internal type: %T\n", sr.Reader)
147155
doCopyV = true
148156
}
149157
if !doCopyV {

0 commit comments

Comments
 (0)