TransferQueue | /src/syncer/transfer_queue.ts | earthstar@v10.0.0-beta.5

Module

x/earthstar/src/syncer/transfer_queue.ts>TransferQueue

Earthstar is a tool for private, undiscoverable, offline-first networks.

earthstar-project/earthstar

Go to Latest

attachment_transfer.ts

AttachmentTransfer

doc_thumbnail_tree.ts

partner_web_client.ts

PartnerWebClient

partner_web_server.ts

EarthstarRangeMessenger

AttachmentTransferOpts

AttachmentTransferProgressEvent

AttachmentTransferReport

AttachmentTransferStatus

SyncAgentFulfilledEvent

SyncAgentHaveEvent

SyncAgentOpts

SyncAgentPruneEvent

SyncAgentRangeMessageEvent

SyncAgentStatus

SyncAgentWantAttachmentEvent

SyncAgentWantEvent

SyncAppetite

SynceAgentNewAttachmentEvent

class TransferQueue

import { TransferQueue } from "https://deno.land/x/earthstar@v10.0.0-beta.5/src/syncer/transfer_queue.ts";

Constructors

new

TransferQueue(activeLimit: number)

Properties

private

active: Set<AttachmentTransfer<unknown>>

private

activeLimit: number

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: PromiseEnroller

private

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[]>

gotAllTransfersRequestedByUs()

hasQueuedTransfer(hash: string, kind: "upload" | "download")

onReportUpdate(cb: (report: Record<string, AttachmentTransferReport[]>) => void)

transfersRequestedByUsFinished()