Struct kcpserver::prelude::KcpPeer

pub struct KcpPeer {
    pub conv: u32,
    pub addr: SocketAddr,
    pub next_update_time: AtomicU32,
    /* private fields */
}

kcp peer 用于管理玩家上下文 以及 读取 和发送 数据

Fields

conv: u32

addr: SocketAddr

next_update_time: AtomicU32

Implementations

impl KcpPeer

pub fn new(kcp: Kcp, conv: u32, addr: SocketAddr) -> Arc<KcpPeer>

pub fn get_addr(&self) -> SocketAddr

获取addr

pub fn get_conv(&self) -> u32

获取conv

pub async fn recv(&self, buf: &mut [u8]) -> KcpResult<usize>

读取数据包

pub async fn send(&self, buf: &[u8]) -> KcpResult<usize>

发送数据

pub async fn flush(&self) -> KcpResult<()>

flush

pub fn get_reader<'a>(self: &'a KCPPeer) -> KcpReader<'a>

获取数据读取器

pub fn get_writer<'a>(self: &'a KCPPeer) -> KcpWriter<'a>

获取写入器

Trait Implementations

impl Display for KcpPeer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for KcpPeer

fn drop(&mut self)

Executes the destructor for this type.