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

strip out extra header chunks in timecode_fixer()

Browse source
This commit is contained in:
Tangent 128 2017-10-04 02:03:19 -04:00
parent 639dc50c35
commit b0b4f204f2
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/timecode_fixer.rs
View file

@ -49,6 +49,7 @@ pub struct ChunkTimecodeFixer<S> {
current_offset: u64, current_offset: u64,
last_observed_timecode: u64, last_observed_timecode: u64,
assumed_duration: u64, assumed_duration: u64,
seen_header: bool
} }
impl<S: Stream<Item = Chunk>> Stream for ChunkTimecodeFixer<S> impl<S: Stream<Item = Chunk>> Stream for ChunkTimecodeFixer<S>
@ -70,6 +71,13 @@ impl<S: Stream<Item = Chunk>> Stream for ChunkTimecodeFixer<S>
} }
self.last_observed_timecode = end + self.current_offset; self.last_observed_timecode = end + self.current_offset;
}, },
Ok(Async::Ready(Some(Chunk::Headers {..}))) => {
if self.seen_header {
return self.poll();
} else {
self.seen_header = true;
}
},
_ => {} _ => {}
}; };
poll_chunk poll_chunk
@ -86,7 +94,8 @@ impl<T: Stream<Item = Chunk>> ChunkStream<T> for T {
stream: self, stream: self,
current_offset: 0, current_offset: 0,
last_observed_timecode: 0, last_observed_timecode: 0,
assumed_duration: 33 assumed_duration: 33,
seen_header: false
} }
} }
} }