parent
01ce5b1ed3
commit
2e5a42c8fe
1 changed files with 12 additions and 3 deletions
|
@ -9,7 +9,7 @@ extern crate framed;
|
||||||
include!("dynamic.rs");
|
include!("dynamic.rs");
|
||||||
|
|
||||||
mod error;
|
mod error;
|
||||||
use error::Result;
|
use error::{Error, Result};
|
||||||
|
|
||||||
// use clap::{App, Arg};
|
// use clap::{App, Arg};
|
||||||
use framed::typed::Receiver;
|
use framed::typed::Receiver;
|
||||||
|
@ -29,7 +29,16 @@ fn try() -> Result<()> {
|
||||||
let mut r = Receiver::<_, UserType>::new(stdin());
|
let mut r = Receiver::<_, UserType>::new(stdin());
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
let v = r.recv()?;
|
let v = r.recv();
|
||||||
println!("decode/main.rs: received value of type {}: {:#?}", USER_TYPE_NAME, v);
|
match v {
|
||||||
|
Ok(v) => {
|
||||||
|
println!("decode/main.rs: received value of type {}: {:#?}",
|
||||||
|
USER_TYPE_NAME, v);
|
||||||
|
},
|
||||||
|
Err(framed::Error::EofBeforeFrame) => return Ok(()),
|
||||||
|
Err(e) => return Err(Error::from(e)),
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Not reached.
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue