From 15386e96380f38cc85f4c782ec98deda0136e69f Mon Sep 17 00:00:00 2001
From: Tangent 128 <Tangent128@gmail.com>
Date: Fri, 29 Sep 2017 02:11:42 -0400
Subject: [PATCH] Repeat test video body a few times
---
src/bin/loop_server.rs | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/bin/loop_server.rs b/src/bin/loop_server.rs
index faa7f13..7dceff5 100644
--- a/src/bin/loop_server.rs
+++ b/src/bin/loop_server.rs
@@ -31,10 +31,11 @@ impl Service for WebmServer {
fn call(&self, req: Request) -> Self::Future {
let response = match (req.method(), req.path()) {
(&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(
once(Ok(self.0.clone()))
- .chain(iter(results))
+ .chain(iter(results.into_iter().cycle().take(20)))
+ .map_err(|_| hyper::Error::Incomplete)
);
Response::new()
.with_header(ContentType("video/webm".parse().unwrap()))