Struct ChannelConnection 

pub struct ChannelConnection<I, O> { /* private fields */ }

基于 mpsc 通道的连接

用于进程内通信，如测试或单机应用

Implementations

impl<I, O> ChannelConnection<I, O>

where I: Send + 'static, O: Send + 'static,

pub fn new( input_rx: Receiver<I>, output_tx: Sender<O>, ) -> ChannelConnection<I, O>

创建新的通道连接

pub fn new_pair( buffer_size: usize, ) -> (ChannelConnection<I, O>, Sender<I>, Receiver<O>)

创建连接对

返回 (connection, input_tx, output_rx)

• connection: 给秘书使用的连接
• input_tx: 用户用来发送输入
• output_rx: 用户用来接收输出

Trait Implementations

impl<I, O> UserConnection for ChannelConnection<I, O>

where I: Send + 'static, O: Send + 'static,

type Input = I

用户输入类型

type Output = O

秘书输出类型

fn receive<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<<ChannelConnection<I, O> as UserConnection>::Input, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, ChannelConnection<I, O>: 'async_trait,

接收用户输入（阻塞）

fn try_receive<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<<ChannelConnection<I, O> as UserConnection>::Input>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, ChannelConnection<I, O>: 'async_trait,

尝试接收用户输入（非阻塞）

fn send<'life0, 'async_trait>( &'life0 self, output: <ChannelConnection<I, O> as UserConnection>::Output, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, ChannelConnection<I, O>: 'async_trait,

发送输出给用户

fn is_connected(&self) -> bool

检查连接是否有效

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, ChannelConnection<I, O>: 'async_trait,

关闭连接