1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
| import { writeSync } from 'fs'
|
| export function writeStream (data, stream, mode = 'default') {
| const write = stream.__write || stream.write
|
| switch (mode) {
| case 'async':
| return new Promise((resolve) => {
| if (write.call(stream, data) === true) {
| resolve()
| } else {
| stream.once('drain', () => { resolve() })
| }
| })
| case 'sync':
| return writeSync(stream.fd, data)
| default:
| return write.call(stream, data)
| }
| }
|
|
