(text string, completedText string, reader io.Reader, length int64, progressBar *visualization.ProgressBar)
| 678 | } |
| 679 | |
| 680 | func (c OrchestratorClient) progressReader(text string, completedText string, reader io.Reader, length int64, progressBar *visualization.ProgressBar) io.Reader { |
| 681 | if progressBar == nil || length < 10*1024*1024 { |
| 682 | return reader |
| 683 | } |
| 684 | return visualization.NewProgressReader(reader, func(progress visualization.Progress) { |
| 685 | displayText := text |
| 686 | if progress.Completed { |
| 687 | displayText = completedText |
| 688 | } |
| 689 | progressBar.UpdateProgress(displayText, progress.BytesRead, length, progress.BytesPerSecond) |
| 690 | }) |
| 691 | } |
| 692 | |
| 693 | func (c OrchestratorClient) httpClientSettings() network.HttpClientSettings { |
| 694 | return *network.NewHttpClientSettings( |
no test coverage detected