You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

readme.md 3.8KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117
  1. # get-stream [![Build Status](https://travis-ci.org/sindresorhus/get-stream.svg?branch=master)](https://travis-ci.org/sindresorhus/get-stream)
  2. > Get a stream as a string, buffer, or array
  3. ## Install
  4. ```
  5. $ npm install --save get-stream
  6. ```
  7. ## Usage
  8. ```js
  9. const fs = require('fs');
  10. const getStream = require('get-stream');
  11. const stream = fs.createReadStream('unicorn.txt');
  12. getStream(stream).then(str => {
  13. console.log(str);
  14. /*
  15. ,,))))))));,
  16. __)))))))))))))),
  17. \|/ -\(((((''''((((((((.
  18. -*-==//////(('' . `)))))),
  19. /|\ ))| o ;-. '((((( ,(,
  20. ( `| / ) ;))))' ,_))^;(~
  21. | | | ,))((((_ _____------~~~-. %,;(;(>';'~
  22. o_); ; )))(((` ~---~ `:: \ %%~~)(v;(`('~
  23. ; ''''```` `: `:::|\,__,%% );`'; ~
  24. | _ ) / `:|`----' `-'
  25. ______/\/~ | / /
  26. /~;;.____/;;' / ___--,-( `;;;/
  27. / // _;______;'------~~~~~ /;;/\ /
  28. // | | / ; \;;,\
  29. (<_ | ; /',/-----' _>
  30. \_| ||_ //~;~~~~~~~~~
  31. `\_| (,~~
  32. \~\
  33. ~~
  34. */
  35. });
  36. ```
  37. ## API
  38. The methods returns a promise that resolves when the `end` event fires on the stream, indicating that there is no more data to be read. The stream is switched to flowing mode.
  39. ### getStream(stream, [options])
  40. Get the `stream` as a string.
  41. #### options
  42. ##### encoding
  43. Type: `string`<br>
  44. Default: `utf8`
  45. [Encoding](https://nodejs.org/api/buffer.html#buffer_buffer) of the incoming stream.
  46. ##### maxBuffer
  47. Type: `number`<br>
  48. Default: `Infinity`
  49. Maximum length of the returned string. If it exceeds this value before the stream ends, the promise will be rejected.
  50. ### getStream.buffer(stream, [options])
  51. Get the `stream` as a buffer.
  52. It honors the `maxBuffer` option as above, but it refers to byte length rather than string length.
  53. ### getStream.array(stream, [options])
  54. Get the `stream` as an array of values.
  55. It honors both the `maxBuffer` and `encoding` options. The behavior changes slightly based on the encoding chosen:
  56. - When `encoding` is unset, it assumes an [object mode stream](https://nodesource.com/blog/understanding-object-streams/) and collects values emitted from `stream` unmodified. In this case `maxBuffer` refers to the number of items in the array (not the sum of their sizes).
  57. - When `encoding` is set to `buffer`, it collects an array of buffers. `maxBuffer` refers to the summed byte lengths of every buffer in the array.
  58. - When `encoding` is set to anything else, it collects an array of strings. `maxBuffer` refers to the summed character lengths of every string in the array.
  59. ## Errors
  60. If the input stream emits an `error` event, the promise will be rejected with the error. The buffered data will be attached to the `bufferedData` property of the error.
  61. ```js
  62. getStream(streamThatErrorsAtTheEnd('unicorn'))
  63. .catch(err => {
  64. console.log(err.bufferedData);
  65. //=> 'unicorn'
  66. });
  67. ```
  68. ## FAQ
  69. ### How is this different from [`concat-stream`](https://github.com/maxogden/concat-stream)?
  70. This module accepts a stream instead of being one and returns a promise instead of using a callback. The API is simpler and it only supports returning a string, buffer, or array. It doesn't have a fragile type inference. You explicitly choose what you want. And it doesn't depend on the huge `readable-stream` package.
  71. ## Related
  72. - [get-stdin](https://github.com/sindresorhus/get-stdin) - Get stdin as a string or buffer
  73. ## License
  74. MIT © [Sindre Sorhus](https://sindresorhus.com)