(p []byte)
| 62 | ) |
| 63 | |
| 64 | func (pt *copyProgressPrinter) Read(p []byte) (int, error) { |
| 65 | n, err := pt.ReadCloser.Read(p) |
| 66 | atomic.AddInt64(pt.total, int64(n)) |
| 67 | return n, err |
| 68 | } |
| 69 | |
| 70 | func copyProgress(ctx context.Context, dst io.Writer, header string, total *int64) (func(), <-chan struct{}) { |
| 71 | done := make(chan struct{}) |
no outgoing calls