跳到主要内容

countQueryCacheOutbox()

function countQueryCacheOutbox(rxdb): Promise<number>;

Defined in: rxdb-plugin-sync/src/query-cache-outbox.ts:401

数一遍所有 QueryCache 仓库在当前分支上还没推回远端的变更行。

Parameters​

ParameterTypeDescription
rxdbRxDBRxDB 实例

Returns​

Promise<number>

待重放的变更行数;没有这类仓库时为 0

Remarks​

口径与 flushQueryCacheOutbox 的取行条件一致(同分支、未推送、未回滚、 水位线之后),只是一次把所有 offlineWrite && !push 的仓库并成一个 OR 组来数, 不必逐仓库往返。

与 HistoryManager.pushableCount$ 不重叠:那一侧按 capability.push 取仓库, 这一侧取它的补集,因此 SyncStateHub 把两个数直接相加是安全的。