Searched refs:resp_rx (Results 1 – 3 of 3) sorted by relevance
47 resp_rx: BoundedReceiver<OutputMessage>, field73 match manager.resp_rx.poll_recv(cx) { in poll()128 resp_rx: BoundedReceiver<OutputMessage>, in new()137 resp_rx, in new()
456 let (resp_tx, resp_rx) = ylong_runtime::sync::mpsc::bounded_channel(20); in ut_http2_body_poll_read()460 conn.receiver.set_receiver(resp_rx); in ut_http2_body_poll_read()
335 let (resp_tx, resp_rx) = bounded_channel(allow_num); in launch()360 ConnManager::new(settings_sync, input_channel.0, resp_rx, req_rx, controller); in launch()