syndicate-lang
/
syndicate-rs
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Tweak output

This commit is contained in:
Tony Garnock-Jones 2019-10-16 14:16:34 +01:00
parent 5b3eec0c95
commit 9f5e9ede5f
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main.rs
View File

@ -166,19 +166,19 @@ impl Peer {
}
async fn run(&mut self) -> Result<(), io::Error> {
println!("Got {:?} {:?}", self.id, &self.frames.get_ref());
println!("{:?}: got {:?}", self.id, &self.frames.get_ref());
let firstpacket = self.frames.next().await;
let dsname = if let Some(Ok(packets::In::Connect(dsname))) = firstpacket {
dsname
} else {
let e: String = format!("Expected initial Connect, got {:?}", firstpacket);
println!("{}", e);
println!("{:?}: {}", self.id, e);
self.frames.send(err(&e)).await?;
return Ok(())
};
println!("{}: connected to dataspace {:?}", self.id, dsname);
println!("{:?}: connected to dataspace {:?}", self.id, dsname);
let mut running = true;
while running {
@ -187,7 +187,7 @@ impl Peer {
frame = self.frames.next().boxed().fuse() => match frame {
Some(res) => match res {
Ok(p) => {
println!("Input {}: {:?}", self.id, &p);
println!("{:?}: input {:?}", self.id, &p);
match p {
packets::In::Turn(actions) => (),
packets::In::Ping() => {
@ -226,9 +226,9 @@ impl Peer {
}
for v in to_send {
if let packets::Out::Err(ref msg) = v {
println!("Connection {} crashed with error {:?}", self.id, msg);
println!("{:?}: Connection crashed with error {:?}", self.id, msg);
} else {
println!("Output {}: {:?}", self.id, &v);
println!("{:?}: Output {:?}", self.id, &v);
}
self.frames.send(v).await?;
}