OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2026-01-03 18:08:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Clean up those unused thingies

Browse Source
This commit is contained in:
Adam Wright
2016-01-09 01:16:59 -08:00
parent 55f1686e52
commit 213963ddda
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/lib.rs
View File

@@ -23,7 +23,6 @@ use std::sync::{
use std::sync::mpsc::{
channel,
Sender,
Receiver,
TryRecvError,
};
use std::thread::{
@@ -63,7 +62,7 @@ impl<T> convert::From<sync::mpsc::SendError<T>> for Error {
pub type Result<T> = std::result::Result<T, Error>;
pub fn handle_conn<F, Request, Reply>(mut stream: TcpStream, f: F) -> Result<()>
pub fn handle_conn<F, Request, Reply>(stream: TcpStream, f: F) -> Result<()>
where Request: 'static + fmt::Debug + Send + serde::de::Deserialize + serde::ser::Serialize,
Reply: 'static + fmt::Debug + serde::ser::Serialize,
F: 'static + Clone + Serve<Request, Reply>
@@ -104,11 +103,11 @@ pub struct Shutdown {
impl Shutdown {
fn wait(self) {
pub fn wait(self) {
self.join_handle.join().unwrap();
}
fn shutdown(self) {
pub fn shutdown(self) {
self.tx.send(()).expect(&line!().to_string());
TcpStream::connect(&self.addr).unwrap();
self.join_handle.join().expect(&line!().to_string());