mirror of
https://github.com/OMGeeky/tarpc.git
synced 2026-02-23 15:49:54 +01:00
Add spaces between items in impls.
This commit is contained in:
@@ -66,6 +66,7 @@ impl<P, D: ?Sized> Dialer for P
|
||||
D: Dialer + 'static
|
||||
{
|
||||
type Stream = D::Stream;
|
||||
|
||||
fn dial(&self) -> io::Result<Self::Stream> {
|
||||
(**self).dial()
|
||||
}
|
||||
|
||||
@@ -7,6 +7,7 @@ pub struct TcpTransport<A: ToSocketAddrs>(pub A);
|
||||
|
||||
impl<A: ToSocketAddrs> super::Transport for TcpTransport<A> {
|
||||
type Listener = TcpListener;
|
||||
|
||||
fn bind(&self) -> io::Result<TcpListener> {
|
||||
TcpListener::bind(&self.0)
|
||||
}
|
||||
@@ -14,6 +15,7 @@ impl<A: ToSocketAddrs> super::Transport for TcpTransport<A> {
|
||||
|
||||
impl<A: ToSocketAddrs> super::Transport for A {
|
||||
type Listener = TcpListener;
|
||||
|
||||
fn bind(&self) -> io::Result<TcpListener> {
|
||||
TcpListener::bind(self)
|
||||
}
|
||||
@@ -21,10 +23,13 @@ impl<A: ToSocketAddrs> super::Transport for A {
|
||||
|
||||
impl super::Listener for TcpListener {
|
||||
type Dialer = TcpDialer<SocketAddr>;
|
||||
|
||||
type Stream = TcpStream;
|
||||
|
||||
fn accept(&self) -> io::Result<TcpStream> {
|
||||
self.accept().map(|(stream, _)| stream)
|
||||
}
|
||||
|
||||
fn dialer(&self) -> io::Result<TcpDialer<SocketAddr>> {
|
||||
self.local_addr().map(|addr| TcpDialer(addr))
|
||||
}
|
||||
@@ -34,12 +39,15 @@ impl super::Stream for TcpStream {
|
||||
fn try_clone(&self) -> io::Result<Self> {
|
||||
self.try_clone()
|
||||
}
|
||||
|
||||
fn set_read_timeout(&self, dur: Option<Duration>) -> io::Result<()> {
|
||||
self.set_read_timeout(dur)
|
||||
}
|
||||
|
||||
fn set_write_timeout(&self, dur: Option<Duration>) -> io::Result<()> {
|
||||
self.set_write_timeout(dur)
|
||||
}
|
||||
|
||||
fn shutdown(&self) -> io::Result<()> {
|
||||
self.shutdown(::std::net::Shutdown::Both)
|
||||
}
|
||||
@@ -52,12 +60,15 @@ impl<A> super::Dialer for TcpDialer<A>
|
||||
where A: ToSocketAddrs
|
||||
{
|
||||
type Stream = TcpStream;
|
||||
|
||||
fn dial(&self) -> io::Result<TcpStream> {
|
||||
TcpStream::connect(&self.0)
|
||||
}
|
||||
}
|
||||
|
||||
impl super::Dialer for str {
|
||||
type Stream = TcpStream;
|
||||
|
||||
fn dial(&self) -> io::Result<TcpStream> {
|
||||
TcpStream::connect(self)
|
||||
}
|
||||
|
||||
@@ -10,6 +10,7 @@ impl<P> super::Transport for UnixTransport<P>
|
||||
where P: AsRef<Path>
|
||||
{
|
||||
type Listener = UnixListener;
|
||||
|
||||
fn bind(&self) -> io::Result<UnixListener> {
|
||||
UnixListener::bind(&self.0)
|
||||
}
|
||||
@@ -22,6 +23,7 @@ impl<P> super::Dialer for UnixDialer<P>
|
||||
where P: AsRef<Path>
|
||||
{
|
||||
type Stream = UnixStream;
|
||||
|
||||
fn dial(&self) -> io::Result<UnixStream> {
|
||||
UnixStream::connect(&self.0)
|
||||
}
|
||||
@@ -29,10 +31,13 @@ impl<P> super::Dialer for UnixDialer<P>
|
||||
|
||||
impl super::Listener for UnixListener {
|
||||
type Stream = UnixStream;
|
||||
|
||||
type Dialer = UnixDialer<PathBuf>;
|
||||
|
||||
fn accept(&self) -> io::Result<UnixStream> {
|
||||
self.accept().map(|(stream, _)| stream)
|
||||
}
|
||||
|
||||
fn dialer(&self) -> io::Result<UnixDialer<PathBuf>> {
|
||||
self.local_addr().and_then(|addr| {
|
||||
match addr.as_pathname() {
|
||||
@@ -50,12 +55,15 @@ impl super::Stream for UnixStream {
|
||||
fn try_clone(&self) -> io::Result<Self> {
|
||||
self.try_clone()
|
||||
}
|
||||
|
||||
fn set_read_timeout(&self, timeout: Option<Duration>) -> io::Result<()> {
|
||||
self.set_read_timeout(timeout)
|
||||
}
|
||||
|
||||
fn set_write_timeout(&self, timeout: Option<Duration>) -> io::Result<()> {
|
||||
self.set_write_timeout(timeout)
|
||||
}
|
||||
|
||||
fn shutdown(&self) -> io::Result<()> {
|
||||
self.shutdown(::std::net::Shutdown::Both)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user