tangent128/webmetro
1
0
Fork 0
Code Issues 1 Pull requests Releases Packages Wiki Activity

Repeat test video body a few times

Browse source
This commit is contained in:
Tangent 128 2017-09-29 02:11:42 -04:00
parent c4fc13fe0b
commit 15386e9638
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/bin/loop_server.rs
View file

@ -31,10 +31,11 @@ impl Service for WebmServer {
fn call(&self, req: Request) -> Self::Future { fn call(&self, req: Request) -> Self::Future {
let response = match (req.method(), req.path()) { let response = match (req.method(), req.path()) {
(&Get, "/loop") => { (&Get, "/loop") => {
let results: Vec<Result<Chunk, hyper::Error>> = self.1.iter().map(|x| Ok(x.clone())).collect(); let results: Vec<Result<Chunk, ()>> = self.1.iter().map(|x| Ok(x.clone())).collect();
let stream: BodyStream<Vec<u8>> = Box::new( let stream: BodyStream<Vec<u8>> = Box::new(
once(Ok(self.0.clone())) once(Ok(self.0.clone()))
.chain(iter(results)) .chain(iter(results.into_iter().cycle().take(20)))
.map_err(|_| hyper::Error::Incomplete)
); );
Response::new() Response::new()
.with_header(ContentType("video/webm".parse().unwrap())) .with_header(ContentType("video/webm".parse().unwrap()))