Estoy tratando de debounce() un Observable con pipe() y encadenando .subscribe() pero por alguna razón, la función en la suscripción todavía se llama más de una docena de veces de una sola vez.

Lo que estoy tratando de hacer es canalizar withChangesForTables y eliminar el rebote de la llamada de sincronización porque quiero que se llame solo cuando se haya realizado un lote completo de cambios. Así que creé un proveedor para la sincronización y lo envolví en mi RootNavigator

withChangesForTables en el código fuente de WatermelonDB

 const SyncContext = createContext(); function useSync() { return useContext(SyncContext); } function SyncProvider({children}) { const [isSyncing, setIsSyncing] = useState(false); const [hasUnsynced, setHasUnsynced] = useState(false); async function checkUnsyncedChanges() { const hasChanges = await hasUnsyncedChanges({ database }); setHasUnsynced(hasChanges); } async function sync() { await checkUnsyncedChanges(); if (!isSyncing && hasUnsynced) { setIsSyncing(true); await synchronizeWithServer(); setIsSyncing(false); } } database.withChangesForTables([ 'table_name', 'table_name2' ]).pipe( skip(1), // ignore records simply becoming `synced` filter(changes => !changes.every(change => change.record.syncStatus === 'synced')), // debounce to avoid syncing in the middle of related actions - I put 100000 to test only debounceTime(100000), ).subscribe({ //calls API endpoint to sync local DB with server next: () => sync(), error: e => console.log(e) }); const value = { isSyncing, hasUnsynced, checkUnsyncedChanges, sync }; return ( <SyncContext.Provider value={value}> {children} </SyncContext.Provider> ); }