import { PayloadIngester } from "https://deno.land/x/willow@0.2.1/src/wgps/data/payload_ingester.ts";
Constructors
new
PayloadIngester(opts: { getStore: GetStoreFn<Prefingerprint, Fingerprint, AuthorisationToken, AuthorisationOpts, NamespaceId, SubspaceId, PayloadDigest>; processReceivedPayload: (bytes: Uint8Array, entryLength: bigint) => Uint8Array; })Properties
private
currentEntry: Entry<NamespaceId, SubspaceId, PayloadDigest> | undefinedprivate
currentIngestion: FIFO<Uint8Array | CANCELLATION>private
entryToRequestPayloadFor: Entry<NamespaceId, SubspaceId, PayloadDigest> | nullprivate
events: FIFO<Uint8Array | { entry: Entry<NamespaceId, SubspaceId, PayloadDigest>; } | CANCELLATION>Methods
push(bytes: Uint8Array, end: boolean)
target(entry: Entry<NamespaceId, SubspaceId, PayloadDigest>, requestIfImmediatelyTerminated?: boolean)
terminate(): Entry<NamespaceId, SubspaceId, PayloadDigest> | null