Skip to content

PieceBatcher

PieceBatcher = object

Defined in: packages/synapse-core/src/sp/create-piece-batcher.ts:95

close: () => Promise<void>

Defined in: packages/synapse-core/src/sp/create-piece-batcher.ts:103

Promise<void>


readonly dataSet: PdpDataSet | undefined

Defined in: packages/synapse-core/src/sp/create-piece-batcher.ts:105


enqueue: (piece) => Promise<PieceResult>

Defined in: packages/synapse-core/src/sp/create-piece-batcher.ts:101

Already on this SP. Join the addPieces window only.

ParameterType
pieceEnqueuePiece

Promise<PieceResult>


flush: () => Promise<FlushResult | undefined>

Defined in: packages/synapse-core/src/sp/create-piece-batcher.ts:102

Promise<FlushResult | undefined>


readonly pending: readonly EnqueuePiece[]

Defined in: packages/synapse-core/src/sp/create-piece-batcher.ts:104


pull: (input) => Promise<PieceResult>

Defined in: packages/synapse-core/src/sp/create-piece-batcher.ts:99

Pull onto this SP (own extraData), then join the addPieces window.

ParameterType
inputPullInput

Promise<PieceResult>


upload: (input) => Promise<UploadResult>

Defined in: packages/synapse-core/src/sp/create-piece-batcher.ts:97

Stream onto this SP, then join the addPieces window.

ParameterType
inputUploadInput

Promise<UploadResult>