Searched refs:temp_buf (Results 1 – 3 of 3) sorted by relevance
496 let mut temp_buf = vec![0; self.read_buf_cap]; in poll_read() localVariable498 data_channel.read(temp_buf.as_mut_slice()).await.map(|n| { in poll_read()499 temp_buf.truncate(n); in poll_read()500 temp_buf in poll_read()535 Poll::Ready(Ok(mut temp_buf)) => { in poll_read()537 let len = std::cmp::min(temp_buf.len(), remaining); in poll_read()538 buf.put_slice(&temp_buf[..len]); in poll_read()539 if temp_buf.len() > remaining { in poll_read()540 temp_buf.drain(..len); in poll_read()541 self.read_fut = ReadFut::RemainingData(temp_buf); in poll_read()
673 let mut temp_buf = vec![0; self.read_buf_cap]; in poll_read() localVariable675 stream.read(temp_buf.as_mut_slice()).await.map(|n| { in poll_read()676 temp_buf.truncate(n); in poll_read()677 temp_buf in poll_read()712 Poll::Ready(Ok(mut temp_buf)) => { in poll_read()714 let len = std::cmp::min(temp_buf.len(), remaining); in poll_read()715 buf.put_slice(&temp_buf[..len]); in poll_read()716 if temp_buf.len() > remaining { in poll_read()717 temp_buf.drain(0..len); in poll_read()718 self.read_fut = ReadFut::RemainingData(temp_buf); in poll_read()
141 temp_buf: Vec<u8>, field153 temp_buf: vec![0u8; capacity], in new()158 let buf = &mut self.temp_buf; in read()