import { DataSender } from "https://deno.land/x/willow@0.2.1/src/wgps/data/data_sender.ts";
Constructors
new
DataSender(opts: { handlesPayloadRequestsTheirs: HandleStore<{ offset: bigint; entry: Entry<NamespaceId, SubspaceId, PayloadDigest>; }>; getStore: GetStoreFn<Prefingerprint, Fingerprint, AuthorisationToken, AuthorisationOpts, NamespaceId, SubspaceId, PayloadDigest>; transformPayload: (chunk: Uint8Array) => Uint8Array; })Properties
private
internalQueue: FIFO<DataSendEntryPack<DynamicToken, NamespaceId, SubspaceId, PayloadDigest> | DataBindPayloadRequestPack>Methods
messages(): AsyncIterable<MsgDataSendEntry<DynamicToken, NamespaceId, SubspaceId, PayloadDigest> | MsgDataReplyPayload | MsgDataSendPayload>
queueEntry()
entry: Entry<NamespaceId, SubspaceId, PayloadDigest>,
staticTokenHandle: bigint,
dynamicToken: DynamicToken,
offset: number,
queuePayloadRequest(handle: bigint)