Struct MockExecution

pub struct MockExecution<FnTime> {
    pub mocked_exchange: ExchangeId,
    pub clock: FnTime,
    pub request_tx: UnboundedSender<MockExchangeRequest>,
    pub event_rx: Receiver<UnindexedAccountEvent>,
}

Fields

mocked_exchange: ExchangeId

clock: FnTime

request_tx: UnboundedSender<MockExchangeRequest>

event_rx: Receiver<UnindexedAccountEvent>

Implementations

impl<FnTime> MockExecution<FnTime>

pub const fn new( mocked_exchange: ExchangeId, clock: FnTime, request_tx: UnboundedSender<MockExchangeRequest>, event_rx: Receiver<UnindexedAccountEvent>, ) -> MockExecution<FnTime>

impl<FnTime> MockExecution<FnTime>

where FnTime: Fn() -> DateTime<Utc>,

pub fn time_request(&self) -> DateTime<Utc>

Trait Implementations

impl<FnTime> Clone for MockExecution<FnTime>

where FnTime: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<FnTime: Debug> Debug for MockExecution<FnTime>

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

Formats the value using the given formatter.

impl<FnTime> ExecutionClient for MockExecution<FnTime>

where FnTime: Fn() -> DateTime<Utc> + Clone + Sync,

const EXCHANGE: ExchangeId = ExchangeId::Mock

type Config = MockExecutionClientConfig<FnTime>

type AccountStream = Pin<Box<dyn Stream<Item = AccountEvent<ExchangeId, AssetNameExchange, InstrumentNameExchange>> + Send>>

fn new(config: Self::Config) -> Self

async fn account_snapshot( &self, _: &[AssetNameExchange], _: &[InstrumentNameExchange], ) -> Result<UnindexedAccountSnapshot, UnindexedClientError>

async fn account_stream( &self, _: &[AssetNameExchange], _: &[InstrumentNameExchange], ) -> Result<Self::AccountStream, UnindexedClientError>

async fn cancel_order( &self, request: OrderRequestCancel<ExchangeId, &InstrumentNameExchange>, ) -> Option<UnindexedOrderResponseCancel>

async fn open_order( &self, request: OrderRequestOpen<ExchangeId, &InstrumentNameExchange>, ) -> Option<Order<ExchangeId, InstrumentNameExchange, Result<Open, UnindexedOrderError>>>

async fn fetch_balances( &self, ) -> Result<Vec<AssetBalance<AssetNameExchange>>, UnindexedClientError>

async fn fetch_open_orders( &self, ) -> Result<Vec<Order<ExchangeId, InstrumentNameExchange, Open>>, UnindexedClientError>

async fn fetch_trades( &self, time_since: DateTime<Utc>, ) -> Result<Vec<Trade<QuoteAsset, InstrumentNameExchange>>, UnindexedClientError>

fn cancel_orders<'a>( &self, requests: impl IntoIterator<Item = OrderRequestCancel<ExchangeId, &'a InstrumentNameExchange>>, ) -> impl Stream<Item = Option<UnindexedOrderResponseCancel>>

fn open_orders<'a>( &self, requests: impl IntoIterator<Item = OrderRequestOpen<ExchangeId, &'a InstrumentNameExchange>>, ) -> impl Stream<Item = Option<Order<ExchangeId, InstrumentNameExchange, Result<Open, UnindexedOrderError>>>>