| 432 | (void)client.getReadableTransportStream().eventData.removeListener(bodyDataListener); |
| 433 | EventEndListener endListener{*this, client}; |
| 434 | (void)client.getReadableTransportStream().eventEnd.removeListener(endListener); |
| 435 | EventCloseListener closeListener{*this, client}; |
| 436 | (void)client.getReadableTransportStream().eventClose.removeListener(closeListener); |
| 437 | |
| 438 | if (transportClose.isValid()) |
| 439 | { |
| 440 | transportClose(client); |
| 441 | } |
| 442 | |
| 443 | const bool readWasDestroyed = client.readableSocketStream.hasBeenDestroyed(); |
| 444 | const bool writeWasDestroyed = client.writableSocketStream.hasBeenDestroyed(); |
| 445 | struct OnCloseDeactivateReadable |
| 446 | { |
| 447 | HttpAsyncServer& pself; |
| 448 | HttpConnection& client; |
| 449 |
no test coverage detected