pub async fn upload_loop(
token: CancellationToken,
listener: Option<Arc<dyn SyncStatusListener>>,
pool: &ConnectionPool,
chunker: Arc<Mutex<&mut Chunker>>,
remote: &Remote,
namespace_id: i32,
local_registry_updated_rx: Receiver<IndexerUpdateEvent>,
) -> Result<(), SyncError>