diff --git a/kit/src/behaviors/swap/mod.rs b/kit/src/behaviors/swap/mod.rs index bfd63e25..52ccc74d 100644 --- a/kit/src/behaviors/swap/mod.rs +++ b/kit/src/behaviors/swap/mod.rs @@ -1,7 +1,4 @@ -use self::{ - bindings::erc20::ERC20, - pool::InputToken, -}; +use self::{bindings::erc20::ERC20, pool::InputToken}; use super::*; use crate::behaviors::token::Response; diff --git a/kit/tests/common.rs b/kit/tests/common.rs index ceb698fe..54179bf3 100644 --- a/kit/tests/common.rs +++ b/kit/tests/common.rs @@ -1,10 +1,6 @@ use std::{collections::VecDeque, marker::PhantomData}; -use arbiter_engine::{ - agent::Agent, - messager::Message, - world::World, -}; +use arbiter_engine::{agent::Agent, messager::Message, world::World}; use dfmm_kit::{ behaviors::{ creator::{self, Create}, diff --git a/kit/tests/swap_integration.rs b/kit/tests/swap_integration.rs index 41918832..aaa2c69a 100644 --- a/kit/tests/swap_integration.rs +++ b/kit/tests/swap_integration.rs @@ -2,8 +2,7 @@ use std::{str::FromStr, time::Duration}; use arbiter_core::{events::stream_event, middleware::ArbiterMiddleware}; use arbiter_engine::messager::To; -use dfmm_kit::{behaviors::MessageTypes, bindings::dfmm::DFMM}; -use ethers::{abi::Address, types::H160}; +use dfmm_kit::bindings::dfmm::DFMM; use futures_util::StreamExt; use tracing::{info, warn}; include!("common.rs"); @@ -26,7 +25,6 @@ async fn run_swapper_constant_sum() { // receivers. TODO: This is a bit of a hack and we could honestly make // the `World::run` better to handle this, but this works for now. tokio::time::sleep(Duration::from_millis(2000)).await; - let mut stream = messager.stream().unwrap(); // TODO: Send a specific message and see if we get the swap. messager