diff options
author | Carl Lerche <me@carllerche.com> | 2019-02-21 11:56:15 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-02-21 11:56:15 -0800 |
commit | 80162306e71c8561873a9c9496d65f2c1387d119 (patch) | |
tree | 83327ca8d9d1326d54e3c679e1fb4eb16775d4be /examples/proxy.rs | |
parent | ab595d08253dd7ee0422144f8dafffa382700976 (diff) |
chore: apply rustfmt to all crates (#917)
Diffstat (limited to 'examples/proxy.rs')
-rw-r--r-- | examples/proxy.rs | 33 |
1 files changed, 17 insertions, 16 deletions
diff --git a/examples/proxy.rs b/examples/proxy.rs index 1df115fd..ae8bf3a4 100644 --- a/examples/proxy.rs +++ b/examples/proxy.rs @@ -24,10 +24,10 @@ extern crate tokio; -use std::sync::{Arc, Mutex}; use std::env; -use std::net::{Shutdown, SocketAddr}; use std::io::{self, Read, Write}; +use std::net::{Shutdown, SocketAddr}; +use std::sync::{Arc, Mutex}; use tokio::io::{copy, shutdown}; use tokio::net::{TcpListener, TcpStream}; @@ -45,7 +45,8 @@ fn main() -> Result<(), Box<std::error::Error>> { println!("Listening on: {}", listen_addr); println!("Proxying to: {}", server_addr); - let done = socket.incoming() + let done = socket + .incoming() .map_err(|e| println!("error accepting socket; error = {:?}", e)) .for_each(move |client| { let server = TcpStream::connect(&server_addr); @@ -68,25 +69,25 @@ fn main() -> Result<(), Box<std::error::Error>> { // After the copy is done we indicate to the remote side that we've // finished by shutting down the connection. let client_to_server = copy(client_reader, server_writer) - .and_then(|(n, _, server_writer)| { - shutdown(server_writer).map(move |_| n) - }); + .and_then(|(n, _, server_writer)| shutdown(server_writer).map(move |_| n)); let server_to_client = copy(server_reader, client_writer) - .and_then(|(n, _, client_writer)| { - shutdown(client_writer).map(move |_| n) - }); + .and_then(|(n, _, client_writer)| shutdown(client_writer).map(move |_| n)); client_to_server.join(server_to_client) }); - let msg = amounts.map(move |(from_client, from_server)| { - println!("client wrote {} bytes and received {} bytes", - from_client, from_server); - }).map_err(|e| { - // Don't panic. Maybe the client just disconnected too soon. - println!("error: {}", e); - }); + let msg = amounts + .map(move |(from_client, from_server)| { + println!( + "client wrote {} bytes and received {} bytes", + from_client, from_server + ); + }) + .map_err(|e| { + // Don't panic. Maybe the client just disconnected too soon. + println!("error: {}", e); + }); tokio::spawn(msg); |