Struct KRPC 

pub struct KRPC {
    pub client: Arc<Client>,
}

Fields

client: Arc<Client>

Implementations

impl KRPC

pub fn new(client: Arc<Client>) -> Self

impl KRPC

pub fn add_event_stream( &self, expression: &Expression, ) -> Result<Stream<Event>, RpcError>

pub fn add_event(&self, expression: &Expression) -> Result<Event, RpcError>

impl KRPC

pub fn add_stream_stream( &self, call: ProcedureCall, start: bool, ) -> Result<Stream<Stream>, RpcError>

pub fn add_stream( &self, call: ProcedureCall, start: bool, ) -> Result<Stream, RpcError>

impl KRPC

pub fn get_client_id_stream(&self) -> Result<Stream<Vec<u8>>, RpcError>

pub fn get_client_id(&self) -> Result<Vec<u8>, RpcError>

impl KRPC

pub fn get_client_name_stream(&self) -> Result<Stream<String>, RpcError>

pub fn get_client_name(&self) -> Result<String, RpcError>

impl KRPC

pub fn get_services_stream(&self) -> Result<Stream<Services>, RpcError>

pub fn get_services(&self) -> Result<Services, RpcError>

impl KRPC

pub fn get_status_stream(&self) -> Result<Stream<Status>, RpcError>

pub fn get_status(&self) -> Result<Status, RpcError>

impl KRPC

pub fn remove_stream_stream(&self, id: u64) -> Result<Stream<()>, RpcError>

pub fn remove_stream(&self, id: u64) -> Result<(), RpcError>

impl KRPC

pub fn set_stream_rate_stream( &self, id: u64, rate: f32, ) -> Result<Stream<()>, RpcError>

pub fn set_stream_rate(&self, id: u64, rate: f32) -> Result<(), RpcError>

impl KRPC

pub fn start_stream_stream(&self, id: u64) -> Result<Stream<()>, RpcError>

pub fn start_stream(&self, id: u64) -> Result<(), RpcError>

impl KRPC

pub fn get_clients_stream( &self, ) -> Result<Stream<Vec<(Vec<u8>, String, String)>>, RpcError>

pub fn get_clients(&self) -> Result<Vec<(Vec<u8>, String, String)>, RpcError>

impl KRPC

pub fn get_current_game_scene_stream( &self, ) -> Result<Stream<GameScene>, RpcError>

pub fn get_current_game_scene(&self) -> Result<GameScene, RpcError>

impl KRPC

pub fn get_paused_stream(&self) -> Result<Stream<bool>, RpcError>

pub fn get_paused(&self) -> Result<bool, RpcError>

impl KRPC

pub fn set_paused_stream(&self, value: bool) -> Result<Stream<()>, RpcError>

pub fn set_paused(&self, value: bool) -> Result<(), RpcError>

Trait Implementations

impl Clone for KRPC

fn clone(&self) -> KRPC

Returns a duplicate of the value.

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

Performs copy-assignment from source.