Searched refs:input_tx (Results 1 – 2 of 2) sorted by relevance
45 input_tx: UnboundedSender<Frame>, field127 input_tx: UnboundedSender<Frame>, in new()136 input_tx, in new()158 .window_update_streams(&self.input_tx)?; in manage_pending_state()285 self.input_tx in poll_send_frame()372 self.input_tx in recv_settings_frame()392 self.input_tx in recv_ping_frame()569 self.input_tx in manage_stream_error()626 self.input_tx in manage_conn_error()673 self.input_tx in send_peer_goaway()[all …]
299 let (input_tx, input_rx) = unbounded_channel(); in new()305 if input_tx.send(settings).is_ok() { in new()310 (input_tx, input_rx), in new()500 input_tx: &UnboundedSender<Frame>, in poll_blocked_message()524 let _ = input_tx.send(frame); in poll_blocked_message()