mirrors/actix-web
1
0
Fork 0
mirror of https://github.com/actix/actix-web.git synced 2024-12-16 21:26:34 +00:00
Code Issues Projects Releases Wiki Activity

add file chunks stream adapter

Browse source
This commit is contained in:
Rob Ede 2022-01-01 22:46:37 +00:00
parent 3f03af1c59
commit c759bdef4c
No known key found for this signature in database
GPG key ID: 97C636207D3EF933
2 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
actix-files/src/lib.rs
View file

@ -33,7 +33,6 @@ mod path_buf;
mod range; mod range;
mod service; mod service;
pub use self::chunked::ChunkedReadFile;
pub use self::directory::Directory; pub use self::directory::Directory;
pub use self::files::Files; pub use self::files::Files;
pub use self::named::NamedFile; pub use self::named::NamedFile;

8
actix-files/src/named.rs
View file

@ -21,8 +21,9 @@ use actix_web::{
Error, HttpMessage, HttpRequest, HttpResponse, Responder, Error, HttpMessage, HttpRequest, HttpResponse, Responder,
}; };
use bitflags::bitflags; use bitflags::bitflags;
use bytes::Bytes;
use derive_more::{Deref, DerefMut}; use derive_more::{Deref, DerefMut};
use futures_core::future::LocalBoxFuture; use futures_core::{future::LocalBoxFuture, Stream};
use mime_guess::from_path; use mime_guess::from_path;
use crate::{encoding::equiv_utf8_text, range::HttpRange}; use crate::{encoding::equiv_utf8_text, range::HttpRange};
@ -527,6 +528,11 @@ impl NamedFile {
res.body(SizedStream::new(length, reader)) res.body(SizedStream::new(length, reader))
} }
/// Returns stream of chunks for the complete file.
pub fn into_chunk_stream(self) -> impl Stream<Item = Result<Bytes, Error>> {
chunked::new_chunked_read(self.md.len(), 0, self.file)
}
} }
/// Returns true if `req` has no `If-Match` header or one which matches `etag`. /// Returns true if `req` has no `If-Match` header or one which matches `etag`.