Struct MykoClient

pub struct MykoClient { /* private fields */ }

Implementations

impl MykoClient

pub fn new() -> MykoClient

pub fn get_status(&self) -> impl Signal<Item = ConnectionStatus>

pub async fn send_event(&self, event: MEvent) -> Result<(), String>

pub fn get_messages(&self) -> impl Stream<Item = Value>

pub fn set_address(&self, addr: Option<String>)

pub async fn get_connection_status(&self) -> ConnectionStatus

pub fn watch_connection_status(&self) -> impl Stream<Item = ConnectionStatus>

pub fn watch_report<T: MykoReport<U> + Clone + Serialize + ReportId, U: DeserializeOwned>( &self, report: &T, ) -> impl Stream<Item = U>

pub fn watch_query<T: Clone + DeserializeOwned + Eventable<T, PT> + PartialEq + Debug, PT: Clone, Q: QueryId + QueryItemType + Serialize + Clone>( &self, query: Q, ) -> impl Stream<Item = Vec<T>>

Trait Implementations

impl Clone for MykoClient

fn clone(&self) -> MykoClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MykoClient

fn default() -> Self

Returns the “default value” for a type.