Changeset 30d0e2c in Klonkt for src/services/guardianship/queues.js
- Timestamp:
- 08/03/2026 06:38:16 AM (5 weeks ago)
- Branches:
- main
- Children:
- 3d882bd
- Parents:
- 69bd747
- File:
-
- 1 edited
-
src/services/guardianship/queues.js (modified) (2 diffs)
Legend:
- Unmodified
- Added
- Removed
-
src/services/guardianship/queues.js
r69bd747 r30d0e2c 12 12 import * as relations from './relations.js'; 13 13 import * as availability from './availability.js'; 14 import * as handshake from './handshake.js'; 14 15 15 16 const collection = (id, items) => ({ … … 22 23 * clients render both without a second fetch. */ 23 24 export function offersCollection(id, slug, me) { 25 // §4.2: a handshake whose candidate could not be dereferenced is deferred, 26 // not decided, and the last Accept may already have landed — so nothing else 27 // would ever retry it. This poll is the schedule. Not awaited: the read 28 // answers with what is true now, and a retry that succeeds surfaces in the 29 // next one. `listForParty` settles closed windows on the way past. 30 handshake.retryDeferred(slug).catch(() => { /* the next read tries again */ }); 24 31 const items = offers.listForParty(slug, me).map((o) => offers.queueItem(o, me)); 25 32 items.push(...availability.lapseQueueItems(slug, me, Date.now()));
Note:
See TracChangeset
for help on using the changeset viewer.
![(please configure the [header_logo] section in trac.ini)](/chrome/site/your_project_logo.png)