Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
Autoparallel committed Feb 8, 2024
1 parent 104ee82 commit 116da22
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
3 changes: 2 additions & 1 deletion arbiter-engine/src/examples/timed_message/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,14 +4,15 @@ const AGENT_ID: &str = "agent";

use std::{pin::Pin, time::Duration};

use super::*;
use anyhow::Result;
use arbiter_macros::Behaviors;
use ethers::types::BigEndianHash;
use futures_util::Stream;
use serde::*;
use tokio::time::timeout;

use super::*;

fn default_max_count() -> Option<u64> {
Some(3)
}
Expand Down
3 changes: 2 additions & 1 deletion arbiter-engine/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down

0 comments on commit 116da22

Please sign in to comment.