| 83 | } |
| 84 | |
| 85 | write( |
| 86 | data: Uint8Array | string, |
| 87 | encoding: BufferEncoding = 'utf8', |
| 88 | callback: (...args: unknown[]) => void = () => {} |
| 89 | ) { |
| 90 | if (data.length === 0) return callback() |
| 91 | if (typeof data === 'string') data = Buffer.from(data, encoding) |
| 92 | |
| 93 | log('sending data direct:', data) |
| 94 | this._cfWriter!.write(data).then( |
| 95 | () => { |
| 96 | log('data sent') |
| 97 | callback() |
| 98 | }, |
| 99 | (err) => { |
| 100 | log('send error', err) |
| 101 | callback(err) |
| 102 | } |
| 103 | ) |
| 104 | return true |
| 105 | } |
| 106 | |
| 107 | end(data = Buffer.alloc(0), encoding: BufferEncoding = 'utf8', callback: (...args: unknown[]) => void = () => {}) { |
| 108 | log('ending CF socket') |