kapitan/IXWebSocket
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

formatting

Browse Source
This commit is contained in:
Benjamin Sergeant 2020-01-09 13:45:31 -08:00
parent 27287aea50
commit 21f42210a2
2 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ws/ws_chat.cpp
View File

@ -10,12 +10,12 @@
// //
#include "nlohmann/json.hpp" #include "nlohmann/json.hpp"
#include <iostream>
#include <ixwebsocket/IXSocket.h> #include <ixwebsocket/IXSocket.h>
#include <ixwebsocket/IXWebSocket.h> #include <ixwebsocket/IXWebSocket.h>
#include <queue> #include <queue>
#include <spdlog/spdlog.h> #include <spdlog/spdlog.h>
#include <sstream> #include <sstream>
#include <iostream>
// for convenience // for convenience
using json = nlohmann::json; using json = nlohmann::json;

19
ws/ws_send.cpp
View File

@ -258,17 +258,18 @@ namespace ix
MsgPack msg(pdu); MsgPack msg(pdu);
Bench bench("Sending file through websocket"); Bench bench("Sending file through websocket");
auto result = _webSocket.sendBinary(msg.dump(), [this, throttle](int current, int total) -> bool { auto result =
spdlog::info("ws_send: Step {} out of {}", current + 1, total); _webSocket.sendBinary(msg.dump(), [this, throttle](int current, int total) -> bool {
spdlog::info("ws_send: Step {} out of {}", current + 1, total);
if (throttle) if (throttle)
{ {
std::chrono::duration<double, std::milli> duration(10); std::chrono::duration<double, std::milli> duration(10);
std::this_thread::sleep_for(duration); std::this_thread::sleep_for(duration);
} }
return _connected; return _connected;
}); });
if (!result.success) if (!result.success)
{ {