import { TransferQueue } from "https://deno.land/x/earthstar@v10.2.2/src/syncer/transfer_queue.ts";
Properties
private
active: Set<AttachmentTransfer<unknown>>private
completed: Set<AttachmentTransfer<unknown>>private
failed: Set<AttachmentTransfer<unknown>>private
reportBus: BlockingBus<Record<string, AttachmentTransferReport[]>>private
reports: Record<string, Record<string, AttachmentTransferReport>>private
transfersRequestedByUsEnroller: PromiseEnrollerprivate
waiting: AttachmentTransfer<unknown>[]Methods
private
activate(transfer: AttachmentTransfer<unknown>)private
admitNext()private
queue(transfer: AttachmentTransfer<unknown>)private
updateTransferStatus(transfer: AttachmentTransfer<unknown>)addTransfer(transfer: AttachmentTransfer<unknown>)
cancel()
getReport(): Record<string, AttachmentTransferReport[]>
hasQueuedTransfer(hash: string, kind: "upload" | "download")
onReportUpdate(cb: (report: Record<string, AttachmentTransferReport[]>) => void)