fix mistake

This commit is contained in:
me-no-dev 2016-09-23 21:56:28 +03:00
parent 1fd73a9262
commit 0adc36b1f6
2 changed files with 3 additions and 3 deletions

View File

@ -113,7 +113,8 @@ AsyncEventSourceClient::AsyncEventSourceClient(AsyncWebServerRequest *request, A
next = NULL;
if(request->hasHeader("Last-Event-ID"))
_lastId = atoi(request->getHeader("Last-Event-ID")->value().c_str());
_client->setRxTimeout(0);
_client->onError(NULL, NULL);
_client->onAck(NULL, NULL);
_client->onPoll(NULL, NULL);
@ -175,7 +176,6 @@ void AsyncEventSource::onConnect(ArEventHandlerFunction cb){
}
void AsyncEventSource::_addClient(AsyncEventSourceClient * client){
client->setRxTimeout(0);
/*char * temp = (char *)malloc(2054);
if(temp != NULL){
memset(temp+1,' ',2048);

View File

@ -250,6 +250,7 @@ AsyncWebSocketClient::AsyncWebSocketClient(AsyncWebServerRequest *request, Async
_lastMessageTime = millis();
_keepAlivePeriod = 0;
next = NULL;
_client->setRxTimeout(0);
_client->onError([](void *r, AsyncClient* c, int8_t error){ ((AsyncWebSocketClient*)(r))->_onError(error); }, this);
_client->onAck([](void *r, AsyncClient* c, size_t len, uint32_t time){ ((AsyncWebSocketClient*)(r))->_onAck(len, time); }, this);
_client->onDisconnect([](void *r, AsyncClient* c){ ((AsyncWebSocketClient*)(r))->_onDisconnect(); delete c; }, this);
@ -621,7 +622,6 @@ void AsyncWebSocket::_handleEvent(AsyncWebSocketClient * client, AwsEventType ty
}
void AsyncWebSocket::_addClient(AsyncWebSocketClient * client){
client->setRxTimeout(0);
if(_clients == NULL){
_clients = client;
return;