networkException/netapp
1
0
Fork 0
forked from lx/netapp
Code Pull requests Activity

fix cargo fmt style

Browse source
This commit is contained in:
Alex 2021-10-12 13:33:42 +02:00
parent 6c8dd95d20
commit 50806b54b7
No known key found for this signature in database
GPG key ID: EDABF9711E244EB1
2 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/netapp.rs
View file

@ -27,9 +27,11 @@ type DynMsg = Box<dyn Any + Send + Sync + 'static>;
type OnConnectHandler = Box<dyn Fn(NodeID, SocketAddr, bool) + Send + Sync>; type OnConnectHandler = Box<dyn Fn(NodeID, SocketAddr, bool) + Send + Sync>;
type OnDisconnectHandler = Box<dyn Fn(NodeID, bool) + Send + Sync>; type OnDisconnectHandler = Box<dyn Fn(NodeID, bool) + Send + Sync>;
pub(crate) type LocalHandler = Box<dyn Fn(DynMsg) -> Pin<Box<dyn Future<Output = DynMsg> + Sync + Send>> + Sync + Send>; pub(crate) type LocalHandler =
Box<dyn Fn(DynMsg) -> Pin<Box<dyn Future<Output = DynMsg> + Sync + Send>> + Sync + Send>;
pub(crate) type NetHandler = Box< pub(crate) type NetHandler = Box<
dyn Fn(NodeID, Bytes) -> Pin<Box<dyn Future<Output = Vec<u8>> + Sync + Send>> + Sync + Send>; dyn Fn(NodeID, Bytes) -> Pin<Box<dyn Future<Output = Vec<u8>> + Sync + Send>> + Sync + Send,
>;
pub(crate) struct Handler { pub(crate) struct Handler {
pub(crate) local_handler: LocalHandler, pub(crate) local_handler: LocalHandler,
@ -132,7 +134,7 @@ impl NetApp {
let netapp2 = netapp.clone(); let netapp2 = netapp.clone();
netapp.add_msg_handler::<HelloMessage, _, _>(move |from: NodeID, msg: HelloMessage| { netapp.add_msg_handler::<HelloMessage, _, _>(move |from: NodeID, msg: HelloMessage| {
netapp2.handle_hello_message(from, msg); netapp2.handle_hello_message(from, msg);
async { } async {}
}); });
netapp netapp

2
src/peering/basalt.rs
View file

@ -290,7 +290,7 @@ impl Basalt {
let basalt2 = basalt.clone(); let basalt2 = basalt.clone();
netapp.add_msg_handler::<PushMessage, _, _>(move |_from: NodeID, push_msg: PushMessage| { netapp.add_msg_handler::<PushMessage, _, _>(move |_from: NodeID, push_msg: PushMessage| {
basalt2.handle_peer_list(&push_msg.peers[..]); basalt2.handle_peer_list(&push_msg.peers[..]);
async move { } async move {}
}); });
basalt basalt