diff --git a/src/p1st/exec_consume_chunks.py b/src/p1st/exec_consume_chunks.py index a63fcff..5719a32 100644 --- a/src/p1st/exec_consume_chunks.py +++ b/src/p1st/exec_consume_chunks.py @@ -73,6 +73,7 @@ def _stdin_worker(queue_get: Queue.get, binary_stdin.write(chunk) # binary_stdin.flush() # TODO: is this required? + # TODO: print total transfer speed and last chunk transfer speed current_time = time.time() elapsed_time = current_time - start_time transferred_bytes += len(chunk)