Module dbus_tokio::connection

source ·
Expand description

Contains connection components.

Example

use dbus_tokio::connection;
use dbus::nonblock::Proxy;
use std::time::Duration;

#[tokio::main]
pub async fn main() -> Result<(), Box<dyn std::error::Error>> {

    // Connect to the D-Bus session bus (this is blocking, unfortunately).
    let (resource, conn) = connection::new_session_sync()?;

    // The resource is a task that should be spawned onto a tokio compatible
    // reactor ASAP. If the resource ever finishes, you lost connection to D-Bus.
    tokio::spawn(async {
        let err = resource.await;
        panic!("Lost connection to D-Bus: {}", err);
    });

    // Make a "proxy object" that contains the destination and path of our method call.
    let proxy = Proxy::new("org.freedesktop.DBus", "/", Duration::from_secs(5), conn);

    // Call the method and await a response. See the argument guide for details about
    // how to send and receive arguments to the method.
    let (names,): (Vec<String>,) = proxy.method_call("org.freedesktop.DBus", "ListNames", ()).await?;

    // Print all the names.
    for name in names { println!("{}", name); }

    Ok(())
}

Structs

  • IOResource
    The I/O Resource should be spawned onto a Tokio compatible reactor.

Enums

Functions

  • from_channel
    Create a connection from channel, you may need to invoke channel.register()? to make sure the channel is usable.
  • new
    Generic connection creator, you might want to use e g new_session_local, new_system_sync etc for convenience.
  • new_session_local
    Creates a connection to the session bus, to use with Tokio’s basic (single-thread) scheduler.
  • new_session_sync
    Creates a connection to the session bus, to use with Tokio’s default (multi-thread) scheduler.
  • new_system_local
    Creates a connection to the system bus, to use with Tokio’s basic (single-thread) scheduler.
  • new_system_sync
    Creates a connection to the system bus, to use with Tokio’s default (multi-thread) scheduler.