()
| 127 | return connection |
| 128 | |
| 129 | async function createSocket() { |
| 130 | let x |
| 131 | try { |
| 132 | x = options.socket |
| 133 | ? (await Promise.resolve(options.socket(options))) |
| 134 | : new net.Socket() |
| 135 | } catch (e) { |
| 136 | error(e) |
| 137 | return |
| 138 | } |
| 139 | x.on('error', error) |
| 140 | x.on('close', closed) |
| 141 | x.on('drain', drain) |
| 142 | return x |
| 143 | } |
| 144 | |
| 145 | async function cancel({ pid, secret }, resolve, reject) { |
| 146 | try { |