Actually drain segments. (#48)
This commit is contained in:
parent
891d6b167b
commit
0e239935a6
|
@ -275,6 +275,7 @@ impl Publishers {
|
|||
let track = track.as_mut().context("track closed")?; // TODO don't make fatal
|
||||
|
||||
track.push_segment(segment);
|
||||
track.drain_segments(time::Instant::now());
|
||||
|
||||
Ok(())
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue