upload_loop

Function upload_loop 

Source
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>