Struct TestSinkNodeTensor 

pub struct TestSinkNodeTensor { /* private fields */ }

test sink

Implementations

impl TestSinkNodeTensor

pub const fn new( node_capabilities: NodeCapabilities, node_policy: NodePolicy, input_placement_acceptance: [PlacementAcceptance; 1], printer: fn(&str), ) -> Self

new

pub fn processed(&self) -> &u32

Returns the number of messages this sink has pushed out thhe graph

Trait Implementations

impl Sink<Tensor<u32, TEST_TENSOR_ELEMENT_COUNT, 2>, 1> for TestSinkNodeTensor

type Error = Infallible

Sink-specific error type for open() or consume().

fn open(&mut self) -> Result<(), Self::Error>

Prepare the sink for consumption (open file/device, connect network, etc.).

fn consume(&mut self, msg: &Message<TestTensor>) -> Result<(), Self::Error>

Consume a single message pulled from port.

fn input_acceptance(&self) -> [PlacementAcceptance; 1]

Input placement acceptances for zero-copy compatibility.

fn capabilities(&self) -> NodeCapabilities

Describe sink capabilities (device streams, degrade tiers, etc.).

fn policy(&self) -> NodePolicy

Provide the node policy bundle (batching/budget/deadlines).

fn select_input(&mut self, occ: &[EdgeOccupancy; IN]) -> Option<usize>

Optional: choose which input to read this step based on occupancies.