#include <xtd/xtd>
using namespace std;
using namespace std::literals;
auto main()->int {
auto terminate_app = false;
auto on_server_accept = [&](shared_ptr<iasync_result> ar) {
while (!terminate_app) {
vector<unsigned char> buffer(256);
size_t number_of_byte_received = socket.
receive(buffer);
if (number_of_byte_received) console::write_line(
ustring(buffer.begin(), buffer.begin() + number_of_byte_received));
}
};
auto on_client_connect = [&](shared_ptr<iasync_result> ar) {
auto counter = 1;
while (!terminate_app) {
auto str = ustring::format(
"socket={}, counter={}", socket.
handle(), counter++);
socket.
send(vector<unsigned char>(str.begin(), str.end()));
this_thread::sleep_for(50ms);
}
};
const size_t client_count = 10;
socket server_socket(address_family::inter_network, socket_type::stream, protocol_type::tcp);
for (auto index = 0U; index < client_count; ++index)
for (auto index = 0U; index < client_count; ++index) {
}
console::read_key();
terminate_app = true;
}