mtcute/packages/client/tests/stream-utils.spec.ts
2021-06-15 03:12:22 +03:00

20 lines
605 B
TypeScript

import { describe, it } from 'mocha'
import { expect } from 'chai'
import { Readable } from 'stream'
import { readStreamUntilEnd } from '../src/utils/stream-utils'
describe('readStreamUntilEnd', () => {
it('should read stream until end', async () => {
const stream = new Readable({
read() {
this.push(Buffer.from('aaeeff', 'hex'))
this.push(Buffer.from('ff33ee', 'hex'))
this.push(null)
},
})
expect((await readStreamUntilEnd(stream)).toString('hex')).eq(
'aaeeffff33ee'
)
})
})