Fix: non-blocking ChannelTransferProgress handling

virtualzone · Apr 20, 2024 · 8a92fc6 · 8a92fc6
1 parent 82844da
commit 8a92fc6
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/commands.go b/commands.go
@@ -154,7 +154,6 @@ func cmdUpload(client *sdk.Client, renderer *OutputRenderer, args []string) {
 			for !done {
 				bytes := <-client.ChannelTransferProgress
 				renderer.updateProgressBar(bytes)
-				time.Sleep(50 * time.Millisecond)
 			}
 		}()
 		go func() {
@@ -189,7 +188,6 @@ func cmdDownload(client *sdk.Client, renderer *OutputRenderer, args []string) {
 		for !done {
 			bytes := <-client.ChannelTransferProgress
 			renderer.updateProgressBar(bytes)
-			time.Sleep(50 * time.Millisecond)
 		}
 	}()
 	go func() {

diff --git a/output-renderer.go b/output-renderer.go
@@ -27,6 +27,7 @@ func (r *OutputRenderer) initProgressBar(maxBytes int64, desc string) {
 		progressbar.OptionOnCompletion(func() { fmt.Printf("\n") }),
 		progressbar.OptionSpinnerType(14),
 		progressbar.OptionSetRenderBlankState(true),
+		progressbar.OptionThrottle(50*time.Millisecond),
 	)
 }