import { PartnerTcp } from "https://deno.land/x/earthstar@v10.2.0/src/syncer/partner_tcp.ts";
Constructors
Type Parameters
IncomingTransferSourceType extends ITcpConn
Properties
private
decoder: TextDecoderprivate
derivedKey: CryptoKeyprivate
encoder: TextEncoderprivate
incomingQueue: AsyncQueue<SyncerEvent>private
messageConn: ITcpConnsyncAppetite: SyncAppetite
Methods
private
encryptBytes(bytes: Uint8Array): Promise<Uint8Array>closeConnection(): Promise<void>
getDownload(opts: GetTransferOpts): Promise<ReadableStream<Uint8Array> | NotSupportedError | undefined>
getEvents(): AsyncIterable<SyncerEvent>
handleTransferRequest(source: ITcpConn, kind: "upload" | "download"): Promise<>
handleUploadRequest(_opts: GetTransferOpts): Promise<NotSupportedError | WritableStream<Uint8Array>>
sendEvent(event: SyncerEvent): Promise<void>