dash-runtime 0.4.0

Sans-IO MPEG-DASH (ISO/IEC 23009-1): MPD model and parser, segment addressing, UTC clock and live-edge arithmetic, and a client for static and dynamic presentations. No I/O, no clock reads.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

//! Shared scaffolding of the live `World` tests.

use super::checks::*;
use super::synth::{Addressing, Geo, MPD_URL, Synth};
use super::world::{MICROS, Shared, Sim, World};
use dash_runtime::client::{DashConfig, PullLimits};
use std::cell::RefCell;
use std::rc::Rc;

pub const AST_US: i64 = 1_700_000_000 * MICROS;
pub const UTC_XSDATE: &str = "http://utc.test/xsdate";
pub const TOLERANCE_US: i64 = 2_000;

pub fn sim_with(synth: Synth, start_after_ast_us: i64, dash: DashConfig) -> (Sim, Geo) {
    let geo = synth.geo();
    let world = World::new(AST_US + start_after_ast_us);
    let sim = Sim::new(MPD_URL, dash, PullLimits::default(), world, Box::new(synth));
    (sim, geo)
}

pub fn with_utc(a: Addressing) -> Synth {
    Synth::new(AST_US, a).with_utc("http-xsdate", UTC_XSDATE)
}

pub fn run_checked(sim: &mut Sim, geo: Geo, secs: i64) -> Vec<SegReq> {
    sim.run_for((secs * MICROS) as u64);
    no_fatal(sim);
    assert!(sim.errors.is_empty(), "{:?}", sim.errors);
    assert!(sim.max_stall_run < 3, "stalled {}", sim.max_stall_run);
    let reqs = segment_requests(sim, geo);
    assert!(!reqs.is_empty());
    assert_contiguous(&reqs);
    assert_no_duplicates(&reqs);
    reqs
}

pub fn sim_shared(
    synth: Synth,
    start_after_ast_us: i64,
    dash: DashConfig,
) -> (Sim, Geo, Rc<RefCell<Synth>>) {
    let geo = synth.geo();
    let handle = Rc::new(RefCell::new(synth));
    let world = World::new(AST_US + start_after_ast_us);
    let sim = Sim::new(
        MPD_URL,
        dash,
        PullLimits::default(),
        world,
        Box::new(Shared(handle.clone())),
    );
    (sim, geo, handle)
}