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