aboutsummaryrefslogtreecommitdiffstats
path: root/src/server.rs
diff options
context:
space:
mode:
authorbnewbold <bnewbold@robocracy.org>2016-05-29 21:15:05 -0400
committerbnewbold <bnewbold@robocracy.org>2016-05-29 21:15:07 -0400
commit37fb8945fad0a034d1565bc4f79f9ab524587fc0 (patch)
treee7dd480223dc1adf093e604839d8bbe943faa0ab /src/server.rs
parentf9b27f5424cb857406a60a2259052dfff1d76439 (diff)
downloaducp-37fb8945fad0a034d1565bc4f79f9ab524587fc0.tar.gz
ucp-37fb8945fad0a034d1565bc4f79f9ab524587fc0.zip
genericize common functions over streams
This makes source_files and sink_files generic over "Streams", defined as types that implement both Read and Write.
Diffstat (limited to 'src/server.rs')
-rw-r--r--src/server.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/server.rs b/src/server.rs
index 390093e..3c79984 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -10,7 +10,7 @@ use std::env;
use std::env::home_dir;
use std::process::exit;
use getopts::Options;
-use utp::{UtpSocket, UtpListener};
+use utp::{UtpSocket, UtpStream, UtpListener};
fn run_server(path: &str, is_recv: bool, recursive: bool, daemonize: bool) {
@@ -51,7 +51,7 @@ fn run_server(path: &str, is_recv: bool, recursive: bool, daemonize: bool) {
let (mut socket, _src) = listener.accept().unwrap();
println!("Got connection from {}", socket.peer_addr().unwrap());
- let mut stream = socket.into();
+ let mut stream: UtpStream = socket.into();
if is_recv {
common::sink_files(&mut stream, path, recursive);