Struct Relay 

pub struct Relay<F, S, P = Pool>
where
    F: Fn(Sender, BytesMut) -> S,
    S: Future<Output = ()>,
    P: Pool + UdpPool,
{ /* private fields */ }

udp relay

Implementations

impl<F, S, P> Relay<F, S, P>

where F: Fn(Sender, BytesMut) -> S, S: Future<Output = ()>, P: Pool + UdpPool,

常规方法

pub fn build<B: FnOnce(Builder<P, F>) -> Builder<P, F>>( b: B, ) -> Result<Self, Error>

pub fn bind_addrs(&self) -> &Vec<SocketAddr>

pub fn relay_fn(&self) -> Arc<F>

pub fn pool(&self) -> Arc<P>

pub fn set_max_conn(&self, max: Option<usize>)

设置最大连接数

pub fn set_keepalive(&self, duration: Option<Duration>)

设置空闲连接保留时长

Trait Implementations

impl<F, S, P> Relay for Relay<F, S, P>

where F: Fn(Sender, BytesMut) -> S + Send + Sync + 'static, S: Future<Output = ()> + Send + 'static, P: Pool + UdpPool + Send + 'static,

实现relay接口

fn poll_run( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

异步运行