diff options
author | hozan23 <hozan23@proton.me> | 2024-03-20 15:20:21 +0100 |
---|---|---|
committer | hozan23 <hozan23@proton.me> | 2024-03-20 15:20:21 +0100 |
commit | 379dca552ca91d22ee007b42f93803ad3dc2b274 (patch) | |
tree | 1ba10573b6ec5213baf46f6ab9c3767e0daa4eed /p2p/src/peer_pool.rs | |
parent | 340957fec147f4429796413f27bbd9b84ba6f141 (diff) |
core: add the option to create a new task group without providing an
executor & remove GlobalExecutor type
Diffstat (limited to 'p2p/src/peer_pool.rs')
-rw-r--r-- | p2p/src/peer_pool.rs | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/p2p/src/peer_pool.rs b/p2p/src/peer_pool.rs index ead6d8f..48499fe 100644 --- a/p2p/src/peer_pool.rs +++ b/p2p/src/peer_pool.rs @@ -11,9 +11,8 @@ use smol::{ }; use karyon_core::{ - async_util::{TaskGroup, TaskResult}, + async_util::{Executor, TaskGroup, TaskResult}, util::decode, - GlobalExecutor, }; use karyon_net::Conn; @@ -54,7 +53,7 @@ pub struct PeerPool { task_group: TaskGroup<'static>, /// A global Executor - executor: GlobalExecutor, + executor: Executor<'static>, /// The Configuration for the P2P network. pub(crate) config: Arc<Config>, @@ -70,7 +69,7 @@ impl PeerPool { conn_queue: Arc<ConnQueue>, config: Arc<Config>, monitor: Arc<Monitor>, - executor: GlobalExecutor, + executor: Executor<'static>, ) -> Arc<Self> { let protocols = RwLock::new(HashMap::new()); let protocol_versions = Arc::new(RwLock::new(HashMap::new())); |