Struct ChannelConnector 

pub struct ChannelConnector { /* private fields */ }

In-memory channel connector for testing and inter-pipeline communication.

Implementations

impl ChannelConnector

pub fn new(name: &str, buffer_size: usize) -> Self

pub fn pair(name: &str, buffer_size: usize) -> (ChannelSender, ChannelReceiver)

Create a paired set of connectors (source + sink) sharing a channel.

Trait Implementations

impl Connector for ChannelConnector

fn name(&self) -> &str

fn connector_type(&self) -> &str

fn send(&self, message: &str) -> Result<(), String>

fn recv(&self, timeout_ms: u64) -> Result<Option<String>, String>