而sid则是因为一个client可以有多个sub,每一个sub要有唯一的id,主要是编号用. stop则是为了client正常关闭使用....这应该是rust的一个bug,在1.41和nightly 1.43都是编译不过去的.所以退而求其次,使用了String....//sub消息格式为SUB subject {queue} {sid}\r\n
pub async fn sub_message(
&mut self,
subject...主要有以下两点
使用futures::select这个宏来辅助实现同时监控多个future
TcpStream如果read到size为0,说明连接已经关闭,无需继续
async fn receive_task...消息格式为SUB subject {queue} {sid}\r\n
//可能由于rustc的bug,导致如果subject是&str,则会报错E0700,暂时使用String来替代
pub