Struct Client 

pub struct Client {
    pub inner: Arc<InnerClient>,
    /* private fields */
}

Fields

inner: Arc<InnerClient>

Implementations

impl Client

pub async fn run_http<T: NashProtocolPipeline + Clone>( &self, request: T, ) -> Result<ResponseOrError<<T::ActionType as NashProtocol>::Response>>

Main entry point to execute Nash API requests via HTTP. Capable of running anything that implements NashProtocolPipeline. All NashProtocol requests automatically do. Other more complex multi-stage interactions like SignAllStates implement the trait manually. This will optionally run before and after hooks if those are defined for the pipeline or request (e.g., get asset nonces if they don’t exist)

impl Client

pub async fn from_keys_path( keys_path: Option<&str>, affiliate_code: Option<String>, turn_off_sign_states: bool, client_id: u64, env: Environment, timeout: Duration, ) -> Result<Self>

Create a new client using an optional keys_path. The client_id is an identifier registered with the absinthe WS connection. It can possibly be removed.

pub async fn from_keys( secret: &str, session: &str, affiliate_code: Option<String>, turn_off_sign_states: bool, client_id: u64, env: Environment, timeout: Duration, ) -> Result<Self>

Create a client using a base64 encoded keylist and session id (contents of Nash produced .json file)

pub async fn run<T: NashProtocolPipeline + Clone>( &self, request: T, ) -> Result<ResponseOrError<<T::ActionType as NashProtocol>::Response>>

Main entry point to execute Nash API requests via websockets. Capable of running anything that implements NashProtocolPipeline. All NashProtocol requests automatically do. Other more complex multi-stage interactions like SignAllStates implement the trait manually. This will optionally run before and after hooks if those are defined for the pipeline or request (e.g., get asset nonces if they don’t exist)

pub async fn subscribe_protocol<T: NashProtocolSubscription + Send + Sync + 'static>( &self, request: T, ) -> Result<UnboundedReceiver<Result<ResponseOrError<<T as NashProtocolSubscription>::SubscriptionResponse>>>>

Entry point for running Nash protocol subscriptions

pub async fn disconnect(&self)

Disconnect the websockets

pub async fn turn_off_sign_states(&self)

pub fn start_background_sign_states_loop(&self, interval: Duration)

pub fn start_background_fill_pool_loop( &self, interval: Duration, chains: Option<Vec<Blockchain>>, )

Trait Implementations

impl Stream for Client

type Item = Result<ResponseOrError<SubscriptionResponse>, ProtocolError>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.