vapcore-network-devp2p 1.12.0

Network and general IO module.

Example usage for creating a network service and adding an IO handler:

extern crate network as net;
extern crate vapcore_network_devp2p as devp2p;
use net::*;
use devp2p::NetworkService;
use std::sync::Arc;
use std::time::Duration;

struct MyHandler;

impl NetworkProtocolHandler for MyHandler {
fn initialize(&self, io: &NetworkContext) {
io.register_timer(0, Duration::from_secs(1));
}

fn read(&self, io: &NetworkContext, peer: &PeerId, packet_id: u8, data: &[u8]) {
println!("Received {} ({} bytes) from {}", packet_id, data.len(), peer);
}

fn connected(&self, io: &NetworkContext, peer: &PeerId) {
println!("Connected {}", peer);
}

fn disconnected(&self, io: &NetworkContext, peer: &PeerId) {
println!("Disconnected {}", peer);
}
}

fn main () {
let mut service = NetworkService::new(NetworkConfiguration::new_local(), None).expect("Error creating network service");
service.start().expect("Error starting service");
service.register_protocol(Arc::new(MyHandler), *b"myp", &[(1u8, 1u8)]);

// Wait for quit condition
// ...
// Drop the service
}