|
|
@ -235,8 +235,8 @@ namespace stream |
|
|
|
s->HandleReceiveTimer (boost::asio::error::make_error_code (boost::asio::error::operation_aborted), buffer, handler); |
|
|
|
s->HandleReceiveTimer (boost::asio::error::make_error_code (boost::asio::error::operation_aborted), buffer, handler); |
|
|
|
else |
|
|
|
else |
|
|
|
{ |
|
|
|
{ |
|
|
|
m_ReceiveTimer.expires_from_now (boost::posix_time::seconds(timeout)); |
|
|
|
s->m_ReceiveTimer.expires_from_now (boost::posix_time::seconds(timeout)); |
|
|
|
m_ReceiveTimer.async_wait ([=](const boost::system::error_code& ecode) |
|
|
|
s->m_ReceiveTimer.async_wait ([=](const boost::system::error_code& ecode) |
|
|
|
{ s->HandleReceiveTimer (ecode, buffer, handler); }); |
|
|
|
{ s->HandleReceiveTimer (ecode, buffer, handler); }); |
|
|
|
} |
|
|
|
} |
|
|
|
}); |
|
|
|
}); |
|
|
|