Forgot to make accept() home for IO
This commit is contained in:
parent
917d3c28b6
commit
73bb4de556
1 changed files with 3 additions and 1 deletions
|
|
@ -719,7 +719,9 @@ impl RtioSocket for UvTcpAcceptor {
|
|||
|
||||
impl RtioTcpAcceptor for UvTcpAcceptor {
|
||||
fn accept(&mut self) -> Result<~RtioTcpStreamObject, IoError> {
|
||||
self.incoming.recv()
|
||||
do self.home_for_io |self_| {
|
||||
self_.incoming.recv()
|
||||
}
|
||||
}
|
||||
|
||||
fn accept_simultaneously(&mut self) -> Result<(), IoError> {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue