Struct StreamDecoder 

pub struct StreamDecoder { /* private fields */ }

Incremental decoder that accumulates ciphertext via update and decodes at finalize using a pre-received entropy snapshot and commitment.

Example

use kk_crypto::{StreamDecoder, StreamEncoder};

let secret = b"our-shared-secret";

// Sender side (streaming encode)
let mut enc = StreamEncoder::new(secret).unwrap();
enc.update(b"Hello ");
enc.update(b"KK!");
let packet = enc.finalize().unwrap();

// Receiver side (streaming decode)
let mut dec = StreamDecoder::new(
    secret,
    packet.entropy_snapshot.clone(),
    packet.commitment.clone(),
);
dec.update(&packet.ciphertext);
let plaintext = dec.finalize().unwrap();
assert_eq!(plaintext, b"Hello KK!");

Implementations

impl StreamDecoder

pub fn new( shared_secret: &[u8], snapshot: EntropySnapshot, commitment: TemporalCommitment, ) -> Self

Create a new streaming decoder.

The caller must supply the entropy snapshot and commitment from the packet header (typically received before the ciphertext body).

pub fn update(&mut self, data: &[u8])

Append ciphertext bytes to the internal buffer.

pub fn finalize(self) -> Result<Vec<u8>>

Consume the decoder, verify integrity, and return plaintext.

Returns KkError::EmptyInput if no bytes were fed, or a temporal verification error if the commitment does not match.

Trait Implementations

impl Drop for StreamDecoder

fn drop(&mut self)

Executes the destructor for this type.