mediaplayer 0.4.3

Safe Rust bindings for MediaPlayer.framework on macOS — now playing, remote commands, artwork, and explicit iOS-only stubs
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
103

//! Example: async streams smoke test.
//!
//! Demonstrates subscribing to `RemoteCommandStream`,
//! `NowPlayingItemChangeStream`, and `NowPlayingSessionStream`.  Each
//! subscription is created and immediately dropped to verify the
//! subscribe → drop → EOF path works on a headless macOS machine.
//!
//! Run with:
//! ```
//! cargo run --features async --example 14_async_streams
//! ```

#![cfg(feature = "async")]

fn main() {
    #[cfg(feature = "async")]
    run();
    #[cfg(not(feature = "async"))]
    {
        eprintln!("Rerun with --features async");
        std::process::exit(1);
    }
}

#[cfg(feature = "async")]
fn run() {
    use mediaplayer::async_api::{
        MediaLibraryChangeStream, NowPlayingItemChangeStream, NowPlayingSessionStream,
        PlaybackStateChangeStream, RemoteCommandStream, VolumeChangeStream,
    };
    use mediaplayer::remote_commands::Command;

    println!("=== mediaplayer async_api smoke test ===");

    // ── Notification streams ────────────────────────────────────────────────
    {
        let s = NowPlayingItemChangeStream::subscribe(8);
        println!(
            "[ok] NowPlayingItemChangeStream  buffered={} closed={}",
            s.buffered_count(),
            s.is_closed()
        );
    }
    {
        let s = PlaybackStateChangeStream::subscribe(8);
        println!(
            "[ok] PlaybackStateChangeStream   buffered={} closed={}",
            s.buffered_count(),
            s.is_closed()
        );
    }
    {
        let s = VolumeChangeStream::subscribe(8);
        println!(
            "[ok] VolumeChangeStream          buffered={} closed={}",
            s.buffered_count(),
            s.is_closed()
        );
    }
    {
        let s = MediaLibraryChangeStream::subscribe(8);
        println!(
            "[ok] MediaLibraryChangeStream    buffered={} closed={}",
            s.buffered_count(),
            s.is_closed()
        );
    }

    // ── RemoteCommandStream ─────────────────────────────────────────────────
    let commands = [
        Command::Play,
        Command::Pause,
        Command::Stop,
        Command::TogglePlayPause,
        Command::NextTrack,
        Command::PreviousTrack,
        Command::SkipForward,
        Command::SkipBackward,
        Command::SeekForward,
        Command::SeekBackward,
    ];
    for cmd in commands {
        let s = RemoteCommandStream::subscribe(cmd, 16);
        // try_next on an idle stream should return None
        assert!(
            s.try_next().is_none(),
            "unexpected buffered event for {cmd:?}"
        );
        println!("[ok] RemoteCommandStream({cmd:?})  buffered={}", s.buffered_count());
    }

    // ── NowPlayingSessionStream ─────────────────────────────────────────────
    {
        let s = NowPlayingSessionStream::subscribe(8);
        println!(
            "[ok] NowPlayingSessionStream     buffered={} closed={}",
            s.buffered_count(),
            s.is_closed()
        );
    }

    println!("=== all streams created and dropped cleanly — PASS ===");
}