Ok(())
}
- fn clone(&self) -> Box<rtio::RtioPipe:Send> {
+ fn clone(&self) -> Box<rtio::RtioPipe + Send> {
box UnixStream {
inner: self.inner.clone(),
read: None,
write: None,
read_deadline: 0,
write_deadline: 0,
- } as Box<rtio::RtioPipe:Send>
+ } as Box<rtio::RtioPipe + Send>
}
fn close_read(&mut self) -> IoResult<()> {
}
impl rtio::RtioUnixListener for UnixListener {
- fn listen(~self) -> IoResult<Box<rtio::RtioUnixAcceptor:Send>> {
+ fn listen(~self) -> IoResult<Box<rtio::RtioUnixAcceptor + Send>> {
self.native_listen().map(|a| {
- box a as Box<rtio::RtioUnixAcceptor:Send>
+ box a as Box<rtio::RtioUnixAcceptor + Send>
})
}
}
}
impl rtio::RtioUnixAcceptor for UnixAcceptor {
- fn accept(&mut self) -> IoResult<Box<rtio::RtioPipe:Send>> {
- self.native_accept().map(|s| box s as Box<rtio::RtioPipe:Send>)
+ fn accept(&mut self) -> IoResult<Box<rtio::RtioPipe + Send>> {
+ self.native_accept().map(|s| box s as Box<rtio::RtioPipe + Send>)
}
fn set_timeout(&mut self, timeout: Option<u64>) {
self.deadline = timeout.map(|i| i + ::io::timer::now()).unwrap_or(0);