FilesExpand file tree

 master

/

buffer.ts

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

32 lines (29 loc) · 716 Bytes

 master

/

buffer.ts

Copy path

Top

File metadata and controls

• Code
• Blame

32 lines (29 loc) · 716 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

import { Transform, TransformOptions } from 'stream'

import { UnsubFn, WaitFn } from './types'

const buffer = (opts: TransformOptions) =>

(wait: WaitFn) => {

let buf: any[] = []

let unsubscribe: UnsubFn

return new Transform({

...opts,

transform (chunk, encoding, callback) {

buf.push(chunk)

if (!unsubscribe) {

unsubscribe = wait(() => {

unsubscribe = undefined

this.push(buf)

buf = []

})

}

callback()

},

flush (callback) {

unsubscribe && unsubscribe()

if (buf.length > 0) {

this.push(buf)

}

callback()

},

})

}

export default buffer