from

An easy way to create a readable Stream.

from(function getChunk(count, next))

from takes a getChunk function and returns a stream.

getChunk is called again and again, after each time the user calls next(), until the user emits 'end'

if pause() is called, the getChunk won't be called again untill resume() is called.

var from = require('from')
 
var stream = 
  from(function getChunk(count, next) {
    //do some sort of data 
    this.emit('data', whatever)
    
    if(itsOver)
      this.emit('end')
 
    //ready to handle the next chunk 
    next()
    //or, if it's sync: 
    return true 
  })

from(array)

from also takes an Array whose elements it emits one after another.

License

MIT / Apache2

We ♥ your boss

Selectively mirror the npm registry inside your firewall. Filter packages based on security, licensing, code quality and more. Build awesome stuff faster. Try npm Enterprise for free…

how? learn more

dominictarr published 2017-03-11T21:58:43.305Z
0.1.7 is the latest of 7 releases
github.com/dominictarr/from
MIT ®

Collaborators list

Stats

148060 downloads in the last day
761453 downloads in the last week
3393158 downloads in the last month
Have an issue? File it. on GitHub
on GitHub

Try it out

Test from in your browser.

Keywords

stream, streams, readable, easy

Dependencies

None

Dependents (23)

@ngxvoice/ngx-voicelistner, wc-starterkit, event-stream, @nhz.io/nopt-stream, level-inverted-index, ordered-merge-stream, skiff-redis, sync-transform, orangejuice, browserify-bundle-factory, relational-join-stream, netmorphic, rpc-with-streams, stream-tester, package-to-dependency-stream, ninja-toolbelt, streamworks, level-map-merge, fs-reverse, @quarterto/react-server, dish, lingon, pui-react-autocomplete