Struct Client 

pub struct Client {
    pub client: Client,
    pub request_semaphore: Arc<Semaphore>,
    /* private fields */
}

Fields

client: Client

request_semaphore: Arc<Semaphore>

Semaphore for limiting simultaneous requests. Shared across clones of this client.

Implementations

impl Client

pub fn set_max_simultaneous_requests(&mut self, max: usize)

Set the maximum number of simultaneous requests allowed.

This creates a new semaphore with the specified number of permits. Note: This will NOT affect existing clones of this client - they will keep using the old semaphore. Call this before cloning if you need all instances to share the same limit.

pub fn update_default_option<O>(&mut self, option: O)

where O: HandlerOption, Self: GetOptions<O::Options>,

Update the default options for this Client

pub fn is_authenticated<O>(&self) -> bool

where O: HandlerOption, Self: GetOptions<O::Options>,

pub async fn request<'a, R, O, Q, B>( &self, method: Method, url: &str, query: Option<&Q>, body: Option<B>, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, B>>::RequestHandler as RequestHandler<B>>::Successful, RequestError>

where O: HttpOption<'a, R, B>, O::RequestHandler: RequestHandler<B>, Self: GetOptions<O::Options>, Q: Serialize + ?Sized + Debug,

see http::Client::request()

pub async fn get<'a, R, O, Q>( &self, url: &str, query: &Q, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, ()>>::RequestHandler as RequestHandler<()>>::Successful, RequestError>

where O: HttpOption<'a, R, ()>, O::RequestHandler: RequestHandler<()>, Self: GetOptions<O::Options>, Q: Serialize + ?Sized + Debug,

see http::Client::get()

pub async fn get_no_query<'a, R, O>( &self, url: &str, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, ()>>::RequestHandler as RequestHandler<()>>::Successful, RequestError>

where O: HttpOption<'a, R, ()>, O::RequestHandler: RequestHandler<()>, Self: GetOptions<O::Options>,

see http::Client::get_no_query()

pub async fn post<'a, R, O, B>( &self, url: &str, body: B, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, B>>::RequestHandler as RequestHandler<B>>::Successful, RequestError>

where O: HttpOption<'a, R, B>, O::RequestHandler: RequestHandler<B>, Self: GetOptions<O::Options>,

see http::Client::post()

pub async fn post_no_body<'a, R, O>( &self, url: &str, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, ()>>::RequestHandler as RequestHandler<()>>::Successful, RequestError>

where O: HttpOption<'a, R, ()>, O::RequestHandler: RequestHandler<()>, Self: GetOptions<O::Options>,

see http::Client::post_no_body()

pub async fn put<'a, R, O, B>( &self, url: &str, body: B, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, B>>::RequestHandler as RequestHandler<B>>::Successful, RequestError>

where O: HttpOption<'a, R, B>, O::RequestHandler: RequestHandler<B>, Self: GetOptions<O::Options>,

see http::Client::put()

pub async fn put_no_body<'a, R, O>( &self, url: &str, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, ()>>::RequestHandler as RequestHandler<()>>::Successful, RequestError>

where O: HttpOption<'a, R, ()>, O::RequestHandler: RequestHandler<()>, Self: GetOptions<O::Options>,

see http::Client::put_no_body()

pub async fn delete<'a, R, O, Q>( &self, url: &str, query: &Q, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, ()>>::RequestHandler as RequestHandler<()>>::Successful, RequestError>

where O: HttpOption<'a, R, ()>, O::RequestHandler: RequestHandler<()>, Self: GetOptions<O::Options>, Q: Serialize + ?Sized + Debug,

see http::Client::delete()

pub async fn delete_no_query<'a, R, O>( &self, url: &str, options: impl IntoIterator<Item = O>, ) -> Result<<<O as HttpOption<'a, R, ()>>::RequestHandler as RequestHandler<()>>::Successful, RequestError>

where O: HttpOption<'a, R, ()>, O::RequestHandler: RequestHandler<()>, Self: GetOptions<O::Options>,

see http::Client::delete_no_query()

pub fn ws_connection<O>( &self, url: &str, options: impl IntoIterator<Item = O>, ) -> Result<WsConnection<O::WsHandler>, UrlError>

where O: WsOption, O::WsHandler: WsHandler, Self: GetOptions<O::Options>,

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 Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Client

fn default() -> Self

Returns the “default value” for a type.

impl GetOptions<BinanceOptions> for Client

Available on crate feature binance only.

fn default_options(&self) -> &BinanceOptions

fn default_options_mut(&mut self) -> &mut BinanceOptions

fn is_authenticated(&self) -> bool

impl GetOptions<BybitOptions> for Client

Available on crate feature bybit only.

fn default_options(&self) -> &BybitOptions

fn default_options_mut(&mut self) -> &mut BybitOptions

fn is_authenticated(&self) -> bool

impl GetOptions<MexcOptions> for Client

Available on crate feature mexc only.

fn default_options(&self) -> &MexcOptions

fn default_options_mut(&mut self) -> &mut MexcOptions

fn is_authenticated(&self) -> bool