Searched refs:req_rx (Results 1 – 3 of 3) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | input.rs | 30 req_rx: UnboundedReceiver<Frame>, field
122 req_rx: UnboundedReceiver<Frame>, in new()
128 req_rx, in new()
192 match self.req_rx.poll_recv(cx) { in poll_recv_frame()
198 match self.req_rx.poll_recv(cx) { in poll_recv_frame()
|
| H A D | manager.rs | 49 req_rx: UnboundedReceiver<ReqMessage>, field
129 req_rx: UnboundedReceiver<ReqMessage>, in new()
138 req_rx, in new()
169 match self.req_rx.poll_recv(cx) { in poll_recv_request()
188 match self.req_rx.poll_recv(cx) { in poll_recv_request()
411 self.req_rx.close(); in recv_go_away_frame()
740 self.req_rx.close(); in exit_with_error()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 300 let (req_tx, req_rx) = unbounded_channel(); in new()
311 req_rx, in new()
331 req_rx: UnboundedReceiver<ReqMessage>, in launch()
360 ConnManager::new(settings_sync, input_channel.0, resp_rx, req_rx, controller); in launch()
|