Function buffer_time

pub fn buffer_time(
    core: &Core,
    binding: &Arc<dyn ProducerBinding>,
    source: NodeId,
    ms: u64,
    pack_fn_id: FnId,
) -> NodeId

Expand description

Collects upstream DATA handles into a buffer and flushes them as a packed tuple every ms milliseconds.

On interval tick: packs buffered handles via binding.pack_tuple(pack_fn_id, &buf), emits the result, releases individual handles, clears buffer.
On upstream COMPLETE: flushes remaining buffer, then completes.
On upstream ERROR: releases buffered handles, forwards error.

buffer_time