diff --git a/arbiter-engine/src/examples/timed_message/mod.rs b/arbiter-engine/src/examples/timed_message/mod.rs index f7c02b96..8ce2b7d9 100644 --- a/arbiter-engine/src/examples/timed_message/mod.rs +++ b/arbiter-engine/src/examples/timed_message/mod.rs @@ -4,7 +4,6 @@ const AGENT_ID: &str = "agent"; use std::{pin::Pin, time::Duration}; -use super::*; use anyhow::Result; use arbiter_macros::Behaviors; use ethers::types::BigEndianHash; @@ -12,6 +11,8 @@ use futures_util::Stream; use serde::*; use tokio::time::timeout; +use super::*; + fn default_max_count() -> Option { Some(3) } diff --git a/arbiter-engine/src/lib.rs b/arbiter-engine/src/lib.rs index f8b12d88..bba5120e 100644 --- a/arbiter-engine/src/lib.rs +++ b/arbiter-engine/src/lib.rs @@ -7,12 +7,13 @@ use std::{collections::HashMap, fmt::Debug, sync::Arc}; -use crate::{errors::ArbiterEngineError, messager::Messager}; use futures_util::future::join_all; use serde::{de::DeserializeOwned, Deserialize, Serialize}; use tokio::task::{spawn, JoinError}; use tracing::{debug, trace, warn}; +use crate::{errors::ArbiterEngineError, messager::Messager}; + pub mod agent; pub mod errors; pub mod examples;