Struct KernelRunner 

pub struct KernelRunner { /* private fields */ }

Implementations

impl KernelRunner

pub fn new( kernel_name: &str, input_ports: usize, output_ports: usize, ) -> Result<Self>

pub fn contract(&self) -> &Contract

pub fn set_options_json(&mut self, json: &str) -> Result<()>

pub fn set_side_packet(&mut self, name: &str, packet: Packet) -> Result<()>

pub fn open(&mut self) -> Result<()>

pub fn process( &mut self, inputs: Vec<Option<Packet>>, timestamp: Timestamp, ) -> Result<Vec<Vec<Packet>>>

pub fn add_input(&mut self, port: usize, packet: Packet) -> Result<()>

pub fn process_pending( &mut self, timestamp: Timestamp, ) -> Result<Vec<Vec<Packet>>>

pub fn try_output(&mut self, port: usize) -> Result<Option<Packet>>

pub fn close(&mut self) -> Result<Vec<Vec<Packet>>>

Close with the same Done activation timestamp used by Graph, collecting any tail output carrying an explicit legal stream timestamp. Pending, unprocessed inputs are discarded; completed output remains readable.

Trait Implementations

impl Drop for KernelRunner

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.