Struct Client 

pub struct Client { /* private fields */ }

Struct used to keep track of a the devices and their properties.

Implementations

impl Client

pub fn new(feedback: Option<UnboundedSender<Command>>) -> Self

pub async fn reset(&mut self, feedback: Option<UnboundedSender<Command>>)

pub async fn get_device<'a>( &'a self, name: &str, ) -> Result<ActiveDevice, Error<()>>

Async method that will wait up to 1 second for the device named name to be defined by the INDI server. The returned ActiveDevice (if present) will be associated with the self client for communicating changes with the INDI server it came from.

Arguments

• name - Name of device on the remote INDI server you wish to get.

Example

use tokio::net::TcpStream;
use twinkle_client::task::Task;
use std::ops::Deref;
use indi::client;

async {
    let (tx, rx) = tokio::sync::mpsc::unbounded_channel();
    let connection = TcpStream::connect("localhost:7624").await.expect("Connecting to server");
    let client = indi::client::Client::new(Some(tx));
    let client_task: tokio::task::JoinHandle<()> = tokio::task::spawn(indi::client::start(client.get_devices().clone(), rx, connection));
    let filter_wheel = client
        .get_device("ASI EFW")
        .await
        .expect("Getting filter wheel");
     
};

pub async fn device<'a, E>(&'a self, name: &str) -> Option<ActiveDevice>

pub fn get_devices(&self) -> &MemoryDeviceStore

Returns the a read-only lock on client’s MemoryDeviceStore.

pub fn shutdown(&mut self)

pub fn send(&self, cmd: Command) -> Result<(), SendError<Command>>

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Drop for Client

fn drop(&mut self)

Executes the destructor for this type.