()
| 195 | } |
| 196 | |
| 197 | async function read() { |
| 198 | try { |
| 199 | let done |
| 200 | , value |
| 201 | while (({ done, value } = await tcp.reader.read(), !done)) |
| 202 | tcp.emit('data', Buffer.from(value)) |
| 203 | } catch (err) { |
| 204 | error(err) |
| 205 | } |
| 206 | } |
| 207 | |
| 208 | async function readFirst() { |
| 209 | const { value } = await tcp.reader.read() |