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