| 1315 | } |
| 1316 | |
| 1317 | void HttpWebSocketConnectionPump::detach() |
| 1318 | { |
| 1319 | if (transport.readableStream != nullptr) |
| 1320 | { |
| 1321 | if (dataListenerAdded) |
| 1322 | { |
| 1323 | (void)transport.readableStream->eventData |
| 1324 | .removeListener<HttpWebSocketConnectionPump, &HttpWebSocketConnectionPump::onData>(*this); |
| 1325 | } |
| 1326 | if (endListenerAdded) |
| 1327 | { |
| 1328 | (void)transport.readableStream->eventEnd |
| 1329 | .removeListener<HttpWebSocketConnectionPump, &HttpWebSocketConnectionPump::onStreamEnd>(*this); |
| 1330 | } |
| 1331 | if (closeListenerAdded) |
| 1332 | { |
| 1333 | (void)transport.readableStream->eventClose |
| 1334 | .removeListener<HttpWebSocketConnectionPump, &HttpWebSocketConnectionPump::onStreamEnd>(*this); |
| 1335 | } |
| 1336 | } |
| 1337 | dataListenerAdded = false; |
| 1338 | endListenerAdded = false; |
| 1339 | closeListenerAdded = false; |
| 1340 | transport.reset(); |
| 1341 | } |
| 1342 | |
| 1343 | Result HttpWebSocketConnectionPump::writeFrame(Span<const char> frame) |
| 1344 | { |
no test coverage detected