Struct ForgeClient 

pub struct ForgeClient { /* private fields */ }

Implementations

impl ForgeClient

pub fn new(config: ForgeClientConfig) -> Self

pub async fn call<TArgs, TResult>( &self, function_name: &str, args: TArgs, ) -> Result<TResult, ForgeClientError>

where TArgs: Serialize, TResult: DeserializeOwned,

pub async fn call_multipart<TResult>( &self, function_name: &str, form: Form, ) -> Result<TResult, ForgeClientError>

where TResult: DeserializeOwned,

pub fn subscribe_query<TArgs, TResult, F>( &self, function_name: &str, args: TArgs, callback: F, ) -> SubscriptionHandle

where TArgs: Serialize + Clone + 'static, TResult: DeserializeOwned + Clone + 'static, F: FnMut(StreamEvent<TResult>) + 'static,

pub fn subscribe_job<TResult, F>( &self, job_id: String, callback: F, ) -> SubscriptionHandle

where TResult: DeserializeOwned + Clone + 'static, F: FnMut(StreamEvent<TResult>) + 'static,

pub fn subscribe_workflow<TResult, F>( &self, workflow_id: String, callback: F, ) -> SubscriptionHandle

where TResult: DeserializeOwned + Clone + 'static, F: FnMut(StreamEvent<TResult>) + 'static,

Trait Implementations

impl Clone for ForgeClient

fn clone(&self) -> ForgeClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.