rustico/core
2
0
Fork 0
Code Issues 9 Pull Requests Projects Releases Wiki Activity

reformat code

Browse Source
This commit is contained in:
Giulio De Pasquale 2021-02-26 16:15:07 +00:00
parent 8bd9eb048d
commit 545bfe28de
4 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/bot.rs
View File

@ -3,12 +3,12 @@ use core::time::Duration;
use log::{error, info};
use tokio::time::sleep;
use crate::BoxError;
use crate::connectors::ExchangeDetails;
use crate::currency::{Symbol, SymbolPair};
use crate::frontend::FrontendManagerHandle;
use crate::managers::ExchangeManager;
use crate::ticker::Ticker;
use crate::BoxError;
pub struct BfxBot {
ticker: Ticker,

4
src/currency.rs
View File

@ -13,8 +13,8 @@ pub struct Symbol {
}
impl<S> From<S> for Symbol
where
S: Into<String>,
where
S: Into<String>,
{
fn from(item: S) -> Self {
Symbol::new(item.into())

15
src/frontend.rs
View File

@ -1,16 +1,15 @@
use log::info;
use tokio::sync::mpsc::{channel, Receiver, Sender};
use crate::events::{ActorMessage};
use crate::BoxError;
use futures_util::stream::TryStreamExt;
use futures_util::StreamExt;
use std::net::SocketAddr;
use futures_util::stream::TryStreamExt;
use futures_util::StreamExt;
use log::info;
use tokio::net::{TcpListener, TcpStream};
use tokio::sync::mpsc::{channel, Receiver, Sender};
use tokio_tungstenite::accept_async;
use crate::BoxError;
use crate::events::ActorMessage;
#[derive(Debug)]
pub struct FrontendManager {
receiver: Receiver<ActorMessage>,

4
src/managers.rs
View File

@ -15,8 +15,8 @@ use crate::connectors::{Client, ExchangeDetails};
use crate::currency::SymbolPair;
use crate::events::{ActionMessage, ActorMessage, Event};
use crate::models::{ActiveOrder, OrderBook, OrderForm, OrderKind, OrderMetadata, Position, PriceTicker};
use crate::strategy::{TrailingStop, MarketEnforce, PositionStrategy};
use crate::sounds::{play_sound, MARKET_ORDER_PLACED_PATH};
use crate::sounds::{MARKET_ORDER_PLACED_PATH, play_sound};
use crate::strategy::{MarketEnforce, PositionStrategy, TrailingStop};
pub type OptionUpdate = (Option<Vec<Event>>, Option<Vec<ActionMessage>>);