aboutsummaryrefslogtreecommitdiff
path: root/p2p/examples/chat.rs
diff options
context:
space:
mode:
authorhozan23 <hozan23@karyontech.net>2024-05-27 00:59:23 +0200
committerhozan23 <hozan23@karyontech.net>2024-05-27 00:59:23 +0200
commitd1c816660c0583db33d160e2ef3e980bef0d5a85 (patch)
tree9eb06e6dbfbe34c6c2f85eee8d2e337b155be103 /p2p/examples/chat.rs
parent385d53ec53e750e342cce78edb793958edf5133e (diff)
p2p: WIP rpc server implementation for the p2p monitor
Diffstat (limited to 'p2p/examples/chat.rs')
-rw-r--r--p2p/examples/chat.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/p2p/examples/chat.rs b/p2p/examples/chat.rs
index d120f50..d162371 100644
--- a/p2p/examples/chat.rs
+++ b/p2p/examples/chat.rs
@@ -11,7 +11,7 @@ use karyon_p2p::{
endpoint::{Endpoint, Port},
keypair::{KeyPair, KeyPairType},
protocol::{ArcProtocol, Protocol, ProtocolEvent, ProtocolID},
- ArcPeer, Backend, Config, P2pError, Version,
+ ArcPeer, Backend, Config, Error, Version,
};
use shared::run_executor;
@@ -58,7 +58,7 @@ impl ChatProtocol {
#[async_trait]
impl Protocol for ChatProtocol {
- async fn start(self: Arc<Self>) -> Result<(), P2pError> {
+ async fn start(self: Arc<Self>) -> Result<(), Error> {
let selfc = self.clone();
let stdin = io::stdin();
let task = self.executor.spawn(async move {
@@ -90,7 +90,7 @@ impl Protocol for ChatProtocol {
Ok(())
}
- fn version() -> Result<Version, P2pError> {
+ fn version() -> Result<Version, Error> {
"0.1.0, 0.1.0".parse()
}