stream.go 340 B

123456789101112131415161718
  1. package plugin
  2. import (
  3. "io"
  4. "log"
  5. )
  6. func copyStream(name string, dst io.Writer, src io.Reader) {
  7. if src == nil {
  8. panic(name + ": src is nil")
  9. }
  10. if dst == nil {
  11. panic(name + ": dst is nil")
  12. }
  13. if _, err := io.Copy(dst, src); err != nil && err != io.EOF {
  14. log.Printf("[ERR] plugin: stream copy '%s' error: %s", name, err)
  15. }
  16. }