| 377 | { |
| 378 | (void)reconnectReadableStream->eventClose |
| 379 | .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectReadableClosed>(*this); |
| 380 | } |
| 381 | if (reconnectWritableStream != nullptr) |
| 382 | { |
| 383 | (void)reconnectWritableStream->eventClose |
| 384 | .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectWritableClosed>(*this); |
| 385 | } |
| 386 | if (reconnectSocketReadableStream != nullptr) |
| 387 | { |
| 388 | (void)reconnectSocketReadableStream->eventClose |
| 389 | .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectSocketReadableClosed>(*this); |
| 390 | } |
| 391 | if (reconnectSocketWritableStream != nullptr) |
| 392 | { |
| 393 | (void)reconnectSocketWritableStream->eventClose |
| 394 | .removeListener<HttpAsyncClient, &HttpAsyncClient::onReconnectSocketWritableClosed>(*this); |
| 395 | } |
| 396 | reconnectClosuresPending = 0; |
| 397 | reconnectCloseInProgress = false; |
nothing calls this directly
no test coverage detected