Searched refs:input_stream (Results 1 – 4 of 4) sorted by relevance
155 let input_stream = incoming_body.stream().unwrap(); in request() localVariable156 let input_stream_pollable = input_stream.subscribe(); in request()162 let mut body_chunk = match input_stream.read(1024 * 1024) { in request()
110 let input_stream = self.table.push_child(input, &tcp_socket)?; in accept() localVariable113 Ok((tcp_socket, input_stream, output_stream)) in accept()
2568 input_stream: &streams::InputStream, in read()2572 BlockingMode::NonBlocking => input_stream.read(read_len), in read()2573 BlockingMode::Blocking => input_stream.blocking_read(read_len), in read()
280 input_stream: Resource<streams::InputStream>, in read()284 match streams::HostInputStream::blocking_read(host, input_stream, max_size).await { in read()