Struct asyncnsq::reader::Reader

pub struct Reader {
    pub stream: Arc<TcpStream>,
    pub max_inflight: i32,
    pub connected: Arc<Mutex<bool>>,
    pub msg_sender: Arc<Sender<Option<Msg>>>,
    pub msg_receiver: Receiver<Option<Msg>>,
    pub data_bufer: Arc<Mutex<Vec<u8>>>,
    pub address: Address,
    pub identify_config: String,
}

the reader struct

Fields

stream: Arc<TcpStream>

max_inflight: i32

connected: Arc<Mutex<bool>>

msg_sender: Arc<Sender<Option<Msg>>>

msg_receiver: Receiver<Option<Msg>>

data_bufer: Arc<Mutex<Vec<u8>>>

address: Address

identify_config: String

Methods

impl Reader

pub async fn reconnect<'_>(&'_ mut self) -> Result<()>

reconnect of the stream. close the old one and create a new one deal with the msgs which use the old closed stream use new stream to deal with the msg

pub async fn connect<'_>(&'_ mut self) -> Result<()>

connect a stream

pub async fn sub<'_, '_, '_>(
    &'_ self,
    nsq_topic: &'_ str,
    nsq_channel: &'_ str
) -> Result<()>

send sub topic command