Асинхронный tcp server

TcpServer server(nPort);
server.BindRecvHandler([&server](Socket* s, staring&& b){ /*работаем с полученным сообщением */ });  //предположительно такая сигнатура
server.StartListen();   //асинхронно запускаем прослушку порта, аксептим сокеты и читаем сообщения, вызывая обработчик
/* выполняем операции параллельно с работой сервера */
server.StopListen();   //останавливаем работу сервера, join к потоку

char buf[BUF_SIZE];
std::list sockets;
while (srv->IsWork()) {  //пусть будет atomic<bool>
    NativeSocket new_s = srv->socket.accept(...);  //NativeSocket - это typedef от системного сокета, srv->socket - прослушивающий сокет (врапер над NativeSocket)
    if (INVALID_SOCKET != new_s) {
        Socket s(new_s);  
        srv->OnAccept(&s);    //тут вызывается обработчик на подключение клиента
        sockets->push_back(std::move(s));
    }
    auto it = sockets.begin();
    while (it != sockets.end()) {
        int len = it->recv(buf, sizeof(buf));   //пытаемся прочитать сообшение с неблокирующего сокета
        if (SOCKET_ERROR != len)
            if (len == 0) {
                sockets.erase(it++);   //клиент штатно отключился
                continue;
            }
            else
                srv->OnRecv(&(*it), std::string(buf, len));  //обработчик полученного сообщения
        }
        ++it;
    }  //while (it != sockets.end())
    Sleep(1); 
} //while (srv->IsWork())