1 | streamBuffers = require('stream-buffers')
|
2 | fs = require 'fs'
|
3 |
|
4 | module.exports =
|
5 | empty: -> fs.createReadStream(__dirname + '/empty')
|
6 | bulk: -> fs.createReadStream(__dirname + '/test.bulk')
|
7 | u0085: -> fs.createReadStream(__dirname + '/bad-u0085.bulk')
|
8 | output: -> new streamBuffers.WritableStreamBuffer()
|
9 | string: (out) -> out.getContentsAsString('utf8')
|
10 | promise: (stream) -> new Promise (rs) ->
|
11 | cb = -> rs stream.getContentsAsString?('utf8') ? null
|
12 | stream.on 'finish', cb
|
13 | stream.on 'end', cb
|