18460000105 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ
..
test 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ
.npmignore 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ
.travis.yml 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ
LICENSE.APACHE2 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ
LICENSE.MIT 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ
index.js 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ
package.json 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ
readme.markdown 0a606483d6 refactor(classes): 重构类转换ref插件 1 mēnesi atpakaļ

readme.markdown

TravisCI Build Status

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