Searched refs:send_flow (Results 1 – 3 of 3) sorted by relevance
204 available = %stream.send_flow.available(), in send_data()216 if stream.send_flow.available() > 0 || stream.buffered_send_data == 0 { in send_data()259 let available = stream.send_flow.available().as_size(); in reserve_capacity()267 let _res = stream.send_flow.claim_capacity(diff); in reserve_capacity()302 flow = ?stream.send_flow in recv_stream_window_update()312 stream.send_flow.inc_window(inc)?; in recv_stream_window_update()337 let available = stream.send_flow.available().as_size(); in reclaim_all_capacity()340 let _res = stream.send_flow.claim_capacity(available); in reclaim_all_capacity()355 let _res = stream.send_flow.claim_capacity(reserved); in reclaim_reserved_capacity()416 debug_assert!(stream.send_flow.available() <= total_requested as usize); in try_assign_capacity()[all …]
41 pub send_flow: FlowControl, field143 let mut send_flow = FlowControl::new(); in new() localVariable153 send_flow in new()166 send_flow, in new()271 let available = self.send_flow.available().as_size() as usize; in capacity()281 let _res = self.send_flow.assign_capacity(capacity); in assign_capacity()286 self.send_flow.available(), in assign_capacity()302 let _res = self.send_flow.send_data(len); in send_data()312 self.send_flow.available(), in send_data()
473 stream.send_flow in apply_remote_settings()478 .send_flow in apply_remote_settings()488 let window_size = stream.send_flow.window_size(); in apply_remote_settings()489 let available = stream.send_flow.available().as_size(); in apply_remote_settings()494 .send_flow in apply_remote_settings()508 stream.send_flow in apply_remote_settings()