avplayer 0.3.3

Safe Rust bindings for Apple's AVPlayer + AVAssetReader — playback and frame-by-frame asset reading on macOS
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//! Example: Tier-1 async API — asset property loading, track loading, seek,
//! and preroll using `pollster::block_on`.
//!
//! Run on a macOS host:
//! ```
//! cargo run --example 21_async_api --features async
//! ```
//!
//! The example uses a synthetic short AIFF produced by the existing smoke test
//! in `target/example-artifacts/test.aiff`.  If that file does not exist the
//! example exits 0 with a notice (headless CI safe).

fn main() -> Result<(), Box<dyn std::error::Error>> {
    pollster::block_on(async_main())
}

async fn async_main() -> Result<(), Box<dyn std::error::Error>> {
    #![allow(clippy::future_not_send)]
    use avplayer::{
        async_api::{AsyncAsset, AsyncPlayer, AsyncPlayerItem},
        Player, PlayerItem, UrlAsset,
    };
    use avplayer::Time;

    let path = "target/example-artifacts/test.aiff";
    if !std::path::Path::new(path).exists() {
        println!("NOTE: {path} not found — run example 01_smoke_surface first.");
        println!("Skipping async example (exit 0).");
        return Ok(());
    }

    // ── Asset property loading ────────────────────────────────────────────────
    println!("=== AsyncAsset::load_properties ===");
    let asset = UrlAsset::from_file_path(path)?;
    let props = AsyncAsset::new(asset.as_asset())
        .load_properties()
        .await?;
    println!("  duration       : {:?}", props.duration);
    println!("  is_playable    : {}", props.is_playable);
    println!("  is_exportable  : {}", props.is_exportable);
    println!("  has_drm        : {}", props.has_protected_content);
    println!("  preferred_rate : {}", props.preferred_rate);
    println!("  metadata items : {}", props.metadata.len());

    // ── All-tracks loading ────────────────────────────────────────────────────
    println!("=== AsyncAsset::load_tracks ===");
    let tracks = AsyncAsset::new(asset.as_asset()).load_tracks().await?;
    println!("  track count: {}", tracks.len());
    for t in &tracks {
        println!(
            "  track {} ({:?})  {}×{}  fps={:?}",
            t.track_id,
            t.media_type,
            t.natural_size.width,
            t.natural_size.height,
            t.nominal_frame_rate,
        );
    }

    // ── Tracks by media type ──────────────────────────────────────────────────
    println!("=== AsyncAsset::load_tracks_with_media_type(\"audio\") ===");
    let audio_tracks = AsyncAsset::new(asset.as_asset())
        .load_tracks_with_media_type("audio")
        .await?;
    println!("  audio track count: {}", audio_tracks.len());

    // ── Track by ID ───────────────────────────────────────────────────────────
    println!("=== AsyncAsset::load_track_with_id ===");
    if let Some(first) = tracks.first() {
        let by_id = AsyncAsset::new(asset.as_asset())
            .load_track_with_id(first.track_id)
            .await?;
        println!("  found track by id={}: {}", first.track_id, by_id.is_some());
    }
    let missing = AsyncAsset::new(asset.as_asset())
        .load_track_with_id(99999)
        .await?;
    println!("  track with id=99999 found: {}", missing.is_some());

    // ── PlayerItem seek ───────────────────────────────────────────────────────
    println!("=== AsyncPlayerItem::seek ===");
    let item = PlayerItem::from_file_path(path)?;
    let seek_time = Time::new(0, 1);
    let finished = AsyncPlayerItem::new(&item).seek(seek_time).await?;
    println!("  seek finished: {finished}");

    // ── Player seek ───────────────────────────────────────────────────────────
    println!("=== AsyncPlayer::seek ===");
    let player = Player::from_item(&item)?;
    let finished = AsyncPlayer::new(&player)
        .seek(Time::new(0, 1))
        .await?;
    println!("  player seek finished: {finished}");

    // ── Player preroll ────────────────────────────────────────────────────────
    println!("=== AsyncPlayer::preroll ===");
    let finished = AsyncPlayer::new(&player).preroll(1.0).await?;
    println!("  preroll finished: {finished}");

    println!("All async examples completed successfully.");
    Ok(())
}