Struct ib_tws_core::AsyncClient
source · pub struct AsyncClient { /* private fields */ }
Implementations
sourceimpl AsyncClient
impl AsyncClient
sourcepub async fn setup<T>(transport: T, client_id: i32) -> Result<Self, Error>where
T: Sink<Request> + Stream<Item = Result<Response, Error>> + SpawnTask + Send + 'static,
<T as Sink<Request>>::Error: Send,
pub async fn setup<T>(transport: T, client_id: i32) -> Result<Self, Error>where
T: Sink<Request> + Stream<Item = Result<Response, Error>> + SpawnTask + Send + 'static,
<T as Sink<Request>>::Error: Send,
Setup a new client with a specified transport.
Errors
Returns an error if either the handshake or initial start API request fails.
sourcepub async fn send(&self, request: Request) -> Result<i32, Error>
pub async fn send(&self, request: Request) -> Result<i32, Error>
Errors
Returns an error if the request channel is closed.
sourcepub fn response_stream(&self) -> Receiver<Response>
pub fn response_stream(&self) -> Receiver<Response>
Get a cloned receiver for the response channel.
pub async fn managed_accounts(&self) -> Vec<String>
pub fn next_valid_order_id(&self) -> i32
pub fn server_version(&self) -> i32
pub async fn request_contract_details(
&self,
message: ReqContractDetails
) -> Result<ContractDetails, Error>
pub async fn request_account_summary(
&self,
message: ReqAccountSummary
) -> Result<impl Stream<Item = Result<AccountSummaryMsg, Error>> + '_, Error>
pub async fn request_market_depth_exchanges(
&self
) -> Result<MktDepthExchangesMsg, Error>
pub async fn request_market_data(
&self,
message: ReqMktData
) -> Result<impl Stream<Item = Result<Response, Error>> + '_, Error>
pub async fn request_market_depth(
&self,
message: ReqMktDepth
) -> Result<impl Stream<Item = Result<Response, Error>> + '_, Error>
pub async fn request_market_data_type(
&self,
market_data_type: MarketDataType
) -> Result<(), Error>
pub async fn set_server_log_level(
&self,
log_level: ServerLogLevel
) -> Result<(), Error>
pub async fn request_tick_by_tick_data(
&self,
message: ReqTickByTickData
) -> Result<impl Stream<Item = Result<Response, Error>> + '_, Error>
pub async fn request_historical_data(
&self,
message: ReqHistoricalData
) -> Result<HistoricalDataMsg, Error>
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for AsyncClient
impl Send for AsyncClient
impl Sync for AsyncClient
impl Unpin for AsyncClient
impl !UnwindSafe for AsyncClient
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more