Struct mpd_client::state_changes::StateChanges

pub struct StateChanges { /* fields omitted */ }

Stream of state change events.

This is emitted by MPD during the client idle loops. You can use this to keep local state such as the current volume or queue in sync with MPD. The stream ending (yielding None) indicates that the MPD server closed the connection, after which no more events will be emitted and attempting to send a command will return an error.

If you don’t care about these, you can just drop this receiver.

use mpd_client::Client;
use futures::stream::StreamExt; // For .next()

async fn print_songs() -> Result<(), Box<dyn std::error::Error>> {
    let (_client, mut state_changes) = Client::connect_to("localhost:6600").await?;

    while let Some(Ok(state_change)) = state_changes.next().await {
        println!("state change: {:?}", state_change);
    }

    Ok(())
}

Trait Implementations

impl Debug for StateChanges

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Stream for StateChanges

type Item = Result<Subsystem, StateChangeError>

Values yielded by the stream.

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

pub fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.