self.set_keepalive(None)
}
- fn clone(&self) -> Box<rtio::RtioTcpStream:Send> {
+ fn clone(&self) -> Box<rtio::RtioTcpStream + Send> {
box TcpStream {
inner: self.inner.clone(),
read_deadline: 0,
write_deadline: 0,
- } as Box<rtio::RtioTcpStream:Send>
+ } as Box<rtio::RtioTcpStream + Send>
}
fn close_write(&mut self) -> IoResult<()> {
}
impl rtio::RtioTcpListener for TcpListener {
- fn listen(~self) -> IoResult<Box<rtio::RtioTcpAcceptor:Send>> {
+ fn listen(~self) -> IoResult<Box<rtio::RtioTcpAcceptor + Send>> {
self.native_listen(128).map(|a| {
- box a as Box<rtio::RtioTcpAcceptor:Send>
+ box a as Box<rtio::RtioTcpAcceptor + Send>
})
}
}
}
impl rtio::RtioTcpAcceptor for TcpAcceptor {
- fn accept(&mut self) -> IoResult<Box<rtio::RtioTcpStream:Send>> {
- self.native_accept().map(|s| box s as Box<rtio::RtioTcpStream:Send>)
+ fn accept(&mut self) -> IoResult<Box<rtio::RtioTcpStream + Send>> {
+ self.native_accept().map(|s| box s as Box<rtio::RtioTcpStream + Send>)
}
fn accept_simultaneously(&mut self) -> IoResult<()> { Ok(()) }
self.set_broadcast(false)
}
- fn clone(&self) -> Box<rtio::RtioUdpSocket:Send> {
+ fn clone(&self) -> Box<rtio::RtioUdpSocket + Send> {
box UdpSocket {
inner: self.inner.clone(),
read_deadline: 0,
write_deadline: 0,
- } as Box<rtio::RtioUdpSocket:Send>
+ } as Box<rtio::RtioUdpSocket + Send>
}
fn set_timeout(&mut self, timeout: Option<u64>) {