Struct StreamPacker 

pub struct StreamPacker { /* private fields */ }

Streaming packer that emits completed packs incrementally.

Example

use seqpacker::stream::{StreamPacker, StreamStrategy};

let mut sp = StreamPacker::new(10, StreamStrategy::NextFit);

// Each add() may return closed packs.
let closed = sp.add(7).unwrap();
assert!(closed.is_empty()); // bin still open

let closed = sp.add(5).unwrap(); // 5 > remaining 3 → closes bin
assert_eq!(closed.len(), 1);
assert_eq!(closed[0].used_capacity(), 7);

// finish() flushes the last open bin.
let remaining = sp.finish();
assert_eq!(remaining.len(), 1);
assert_eq!(remaining[0].used_capacity(), 5);

Implementations

impl StreamPacker

pub fn new(capacity: usize, strategy: StreamStrategy) -> Self

Create a new streaming packer.

pub fn with_k(capacity: usize, strategy: StreamStrategy, k: usize) -> Self

Create a streaming packer with a custom k for Harmonic.

k is ignored for NextFit.

pub fn add(&mut self, length: usize) -> Result<Vec<Pack>>

Add a sequence length and return any packs that are now complete.

Errors

Returns PackError::SequenceTooLong if length exceeds capacity.

pub fn finish(self) -> Vec<Pack>

Flush all remaining open bins and return them as packs.

pub fn sequences_added(&self) -> usize

Number of sequences added so far.

pub fn strategy(&self) -> StreamStrategy

The streaming strategy in use.