File size: 1,090 Bytes
3e05655 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 | export function createWorkerTransport<T extends { id: number; key: string }>(input: {
post: (request: T) => void
supersede: (request: T) => void
}) {
const active = new Map<string, T>()
const queued = new Map<string, T>()
return {
send(request: T) {
if (!active.has(request.key)) {
active.set(request.key, request)
input.post(request)
return
}
const previous = queued.get(request.key)
if (previous) input.supersede(previous)
queued.set(request.key, request)
},
complete(key: string, id: number) {
if (active.get(key)?.id !== id) return
active.delete(key)
const next = queued.get(key)
if (!next) return
queued.delete(key)
active.set(key, next)
input.post(next)
},
dispose(key: string) {
active.delete(key)
const request = queued.get(key)
if (request) input.supersede(request)
queued.delete(key)
},
reset() {
queued.forEach(input.supersede)
queued.clear()
active.clear()
},
queued: () => queued.size,
}
}
|