Detect if AsyncWebSocketClient can send data to server and add AsyncWebServer::end() (#501)
* added AsyncWebServer::end() * added AsyncWebServer::end() * added bool AsyncWebSocketClient::canSend() * Fix comparison with WS_MAX_QUEUED_MESSAGES * Fix comparison with WS_MAX_QUEUED_MESSAGES
This commit is contained in:
parent
6dcea3f5e7
commit
5ef7ffcd41
|
@ -551,7 +551,7 @@ void AsyncWebSocketClient::_queueMessage(AsyncWebSocketMessage *dataMessage){
|
||||||
delete dataMessage;
|
delete dataMessage;
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if(_messageQueue.length() > WS_MAX_QUEUED_MESSAGES){
|
if(_messageQueue.length() >= WS_MAX_QUEUED_MESSAGES){
|
||||||
ets_printf("ERROR: Too many messages queued\n");
|
ets_printf("ERROR: Too many messages queued\n");
|
||||||
delete dataMessage;
|
delete dataMessage;
|
||||||
} else {
|
} else {
|
||||||
|
|
|
@ -210,6 +210,8 @@ class AsyncWebSocketClient {
|
||||||
void binary(const __FlashStringHelper *data, size_t len);
|
void binary(const __FlashStringHelper *data, size_t len);
|
||||||
void binary(AsyncWebSocketMessageBuffer *buffer);
|
void binary(AsyncWebSocketMessageBuffer *buffer);
|
||||||
|
|
||||||
|
bool canSend() { return _messageQueue.length() < WS_MAX_QUEUED_MESSAGES; }
|
||||||
|
|
||||||
//system callbacks (do not call)
|
//system callbacks (do not call)
|
||||||
void _onAck(size_t len, uint32_t time);
|
void _onAck(size_t len, uint32_t time);
|
||||||
void _onError(int8_t);
|
void _onError(int8_t);
|
||||||
|
|
Loading…
Reference in New Issue