Struct salvo_core::writing::ReadSeeker

pub struct ReadSeeker<R> { /* private fields */ }

ReadSeeker is used to write data to Response from a reader which implements AsyncRead and AsyncSeek.

Example

use salvo_core::prelude::*;
use salvo_core::writing::ReadSeeker;

#[handler]
async fn video_stream(req: &mut Request, res: &mut Response) {
    let file = tokio::fs::File::open("video.mp4").await.unwrap();
    res.add_header("Content-Type", "video/mp4", true).unwrap();
    let length = file.metadata().await.unwrap().len();
    ReadSeeker::new(file, length).send(req.headers(), res).await;
}

Implementations

impl<R> ReadSeeker<R>

where R: AsyncSeek + AsyncRead + Unpin + Send + 'static,

pub fn new(reader: R, length: u64) -> Self

Create a new ReadSeeker from a reader which implements AsyncRead and AsyncSeek.

pub fn last_modified(self, time: SystemTime) -> Self

Set the last modified time for the response.

pub fn etag(self, etag: ETag) -> Self

Set the ETag header for the response.

pub async fn send(self, req_headers: &HeaderMap, res: &mut Response)

Consume self and send content to Response.

Trait Implementations

impl<R: Debug> Debug for ReadSeeker<R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<R> Writer for ReadSeeker<R>

where R: AsyncSeek + AsyncRead + Unpin + Send + 'static,

fn write<'life0, 'life1, 'life2, 'async_trait>( self, req: &'life0 mut Request, _depot: &'life1 mut Depot, res: &'life2 mut Response ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Write data to Response.