diff options
Diffstat (limited to 'src/pkg/io/multi.go')
-rw-r--r-- | src/pkg/io/multi.go | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/src/pkg/io/multi.go b/src/pkg/io/multi.go index 2c7e816cf..e26cc53e9 100644 --- a/src/pkg/io/multi.go +++ b/src/pkg/io/multi.go @@ -26,9 +26,12 @@ func (mr *multiReader) Read(p []byte) (n int, err error) { // MultiReader returns a Reader that's the logical concatenation of // the provided input readers. They're read sequentially. Once all -// inputs are drained, Read will return EOF. +// inputs have returned EOF, Read will return EOF. If any of the readers +// return a non-nil, non-EOF error, Read will return that error. func MultiReader(readers ...Reader) Reader { - return &multiReader{readers} + r := make([]Reader, len(readers)) + copy(r, readers) + return &multiReader{r} } type multiWriter struct { @@ -52,5 +55,7 @@ func (t *multiWriter) Write(p []byte) (n int, err error) { // MultiWriter creates a writer that duplicates its writes to all the // provided writers, similar to the Unix tee(1) command. func MultiWriter(writers ...Writer) Writer { - return &multiWriter{writers} + w := make([]Writer, len(writers)) + copy(w, writers) + return &multiWriter{w} } |