import { TransferManager } from "https://deno.land/x/earthstar@v10.0.0-alpha.2/src/syncer/transfer_manager.ts";
Constructors
new
TransferManager(opts: TransferManagerOpts<FormatsType, IncomingAttachmentSourceType>)Properties
private
expectedTransferPromises: Map<string, Deferred<void>>private
formats: FormatsArg<FormatsType>private
formatsLookup: Record<string, FormatArg<FormatsType>>private
madeAllAttachmentRequestsEnroller: PromiseEnrollerprivate
partner: ISyncPartner<IncomingAttachmentSourceType>private
queue: TransferQueueprivate
receivedAllExpectedTransfersEnroller: PromiseEnrollerprivate
reportDidUpdateBus: BlockingBus<Record<string, AttachmentTransferReport[]>>Methods
private
queueTransfer(transfer: AttachmentTransfer<unknown>)cancel()
handleDownload(doc: FormatDocType<FormatsType>, replica: Replica): Promise<boolean>
handleTransferRequest(unnamed 0: { replica: Replica; formatName: string; path: Path; author: AuthorAddress; source: IncomingAttachmentSourceType; kind: "upload" | "download"; })
handleUpload(transferOpts: Omit<GetTransferOpts, "syncerId">, replica: Replica): Promise<boolean>
onReportUpdate(cb: () => void)
registerExpectedTransfer(share: ShareAddress, hash: string)
registerOtherSyncerId(id: string)
registerSyncAgent(agent: SyncAgent<FormatsType>)