(sock: NodeSock)
| 319 | }, |
| 320 | |
| 321 | close(sock: NodeSock): number { |
| 322 | // Signal the pump to stop before touching the reader. |
| 323 | sock.closed = true; |
| 324 | notifyDataAvailable(sock); |
| 325 | maybeResumePump(sock); |
| 326 | |
| 327 | if (sock.wcgSocket) { |
| 328 | sock.reader = null; |
| 329 | sock.writer = null; |
| 330 | sock.wcgSocket.close().catch(() => {}); |
| 331 | sock.wcgSocket = null; |
| 332 | } |
| 333 | sock.recvBuffer = []; |
| 334 | sock.recvBufferBytes = 0; |
| 335 | sock.connected = false; |
| 336 | sock.connecting = false; |
| 337 | return 0; |
| 338 | }, |
| 339 | |
| 340 | async connectAsync( |
| 341 | sock: NodeSock, |
searching dependent graphs…