pub struct ChunkedReadFile<D: 'static + Send + Buf + From<Vec<u8>> + From<&'static [u8]>, E: 'static + Send + Into<Box<dyn StdError + Send + Sync>> + From<Box<dyn StdError + Send + Sync>>> { /* private fields */ }Expand description
HTTP entity created from a std::fs::File which reads the file chunk-by-chunk within
a tokio::task::block_in_place closure.
ChunkedReadFile is cheap to clone and reuse for many requests.
Expects to be served from a tokio threadpool.
type BoxedError = Box<dyn std::error::Error + 'static + Send + Sync>;
async fn serve_dictionary(req: Request<Body>) -> Result<Response<Body>, BoxedError> {
let f = tokio::task::block_in_place::<_, Result<_, BoxedError>>(
move || {
let f = std::fs::File::open("/usr/share/dict/words")?;
let mut headers = http::header::HeaderMap::new();
headers.insert(header::CONTENT_TYPE, HeaderValue::from_static("text/plain"));
Ok(http_serve::ChunkedReadFile::new(f, headers)?)
},
)?;
Ok(http_serve::serve(f, &req))
}Implementations§
Source§impl<D, E> ChunkedReadFile<D, E>
impl<D, E> ChunkedReadFile<D, E>
Sourcepub fn new(file: File, headers: HeaderMap) -> Result<Self, Error>
pub fn new(file: File, headers: HeaderMap) -> Result<Self, Error>
Creates a new ChunkedReadFile.
read(2) calls will be wrapped in tokio::task::block_in_place calls so that they don’t
block the tokio reactor thread on local disk I/O. Note that std::fs::File::open and
this constructor (specifically, its call to fstat(2)) may also block, so they typically
should be wrapped in tokio::task::block_in_place as well.
Sourcepub fn new_with_metadata(
file: File,
metadata: &Metadata,
headers: HeaderMap,
) -> Result<Self, Error>
pub fn new_with_metadata( file: File, metadata: &Metadata, headers: HeaderMap, ) -> Result<Self, Error>
Creates a new ChunkedReadFile, with presupplied metadata.
This is an optimization for the case where the caller has already called fstat(2).
Note that on Windows, this still may perform a blocking file operation, so it should
still be wrapped in tokio::task::block_in_place.
Trait Implementations§
Source§impl<D: Clone + 'static + Send + Buf + From<Vec<u8>> + From<&'static [u8]>, E: Clone + 'static + Send + Into<Box<dyn StdError + Send + Sync>> + From<Box<dyn StdError + Send + Sync>>> Clone for ChunkedReadFile<D, E>
impl<D: Clone + 'static + Send + Buf + From<Vec<u8>> + From<&'static [u8]>, E: Clone + 'static + Send + Into<Box<dyn StdError + Send + Sync>> + From<Box<dyn StdError + Send + Sync>>> Clone for ChunkedReadFile<D, E>
Source§fn clone(&self) -> ChunkedReadFile<D, E>
fn clone(&self) -> ChunkedReadFile<D, E>
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl<D, E> Entity for ChunkedReadFile<D, E>
impl<D, E> Entity for ChunkedReadFile<D, E>
type Error = E
Source§fn get_range(
&self,
range: Range<u64>,
) -> Box<dyn Stream<Item = Result<Self::Data, Self::Error>> + Send + Sync>
fn get_range( &self, range: Range<u64>, ) -> Box<dyn Stream<Item = Result<Self::Data, Self::Error>> + Send + Sync>
range.Source§fn add_headers(&self, h: &mut HeaderMap)
fn add_headers(&self, h: &mut HeaderMap)
Content-Type to the supplied Headers object.
In particular, these headers are the “other representation header fields” described by RFC
7233 section 4.1; they should exclude
Content-Range, Date, Cache-Control, ETag, Expires, Content-Location, and Vary. Read moreSource§fn etag(&self) -> Option<HeaderValue>
fn etag(&self) -> Option<HeaderValue>
Source§fn last_modified(&self) -> Option<SystemTime>
fn last_modified(&self) -> Option<SystemTime>
serve may serve an earlier Last-Modified: date than the one returned here if
this time is in the future, as required by RFC 7232 section
2.2.1.