Searched refs:resp_tx (Results 1 – 3 of 3) sorted by relevance
46 resp_tx: BoundedSender<OutputMessage>, field65 resp_tx: BoundedSender<OutputMessage>, in new()73 resp_tx, in new()214 let sender = self.resp_tx.clone(); in transmit_message()
456 let (resp_tx, resp_rx) = ylong_runtime::sync::mpsc::bounded_channel(20); in ut_http2_body_poll_read()479 let _ = resp_tx in ut_http2_body_poll_read()482 let _ = resp_tx in ut_http2_body_poll_read()485 let _ = resp_tx in ut_http2_body_poll_read()
335 let (resp_tx, resp_rx) = bounded_channel(allow_num); in launch()353 let mut recv = RecvData::new(decoder, recv_settings_sync, read, resp_tx); in launch()