|
|
@ -189,6 +189,13 @@ impl TMClient {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
fn process(self: &TMClient) {
|
|
|
|
fn process(self: &TMClient) {
|
|
|
|
|
|
|
|
// Check if there's any incoming requests to process(aka send)
|
|
|
|
|
|
|
|
match self.requests.try_recv() {
|
|
|
|
|
|
|
|
Ok(request) => println!("Got incoming request"),
|
|
|
|
|
|
|
|
Err(error) => {},
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Do per-call processing(currently just pretending to receive an empty notice)
|
|
|
|
match self.notices.send(tm::Notice::default()) {
|
|
|
|
match self.notices.send(tm::Notice::default()) {
|
|
|
|
Ok(_) => println!("Received notice"),
|
|
|
|
Ok(_) => println!("Received notice"),
|
|
|
|
Err(error) => println!("Recv error {}", error),
|
|
|
|
Err(error) => println!("Recv error {}", error),
|
|
|
|