countQueryCacheOutbox()
function countQueryCacheOutbox(rxdb): Promise<number>;
Defined in: rxdb-plugin-sync/src/query-cache-outbox.ts:401
数一遍所有 QueryCache 仓库在当前分支上还没推回远端的变更行。
Parameters
| Parameter | Type | Description |
|---|---|---|
rxdb | RxDB | RxDB 实例 |
Returns
Promise<number>
待重放的变更行数;没有这类仓库时为 0
Remarks
口径与 flushQueryCacheOutbox 的取行条件一致(同分支、未推送、未回滚、
水位线之后),只是一次把所有 offlineWrite && !push 的仓库并成一个 OR 组来数,
不必逐仓库往返。
与 HistoryManager.pushableCount$ 不重叠:那一侧按 capability.push 取仓库,
这一侧取它的补集,因此 SyncStateHub 把两个数直接相加是安全的。