合并2

将多条流按顺序或平行合并为一流.

安装

安装方式 无

npm install merge2

使用量

const gulp = require('gulp')
const merge2 = require('merge2')
const concat = require('gulp-concat')
const minifyHtml = require('gulp-minify-html')
const ngtemplate = require('gulp-ngtemplate')

gulp.task('app-js', function () {
  return merge2(
      gulp.src('static/src/tpl/*.html')
        .pipe(minifyHtml({empty: true}))
        .pipe(ngtemplate({
          module: 'genTemplates',
          standalone: true
        })
      ), gulp.src([
        'static/src/js/app.js',
        'static/src/js/locale_zh-cn.js',
        'static/src/js/router.js',
        'static/src/js/tools.js',
        'static/src/js/services.js',
        'static/src/js/filters.js',
        'static/src/js/directives.js',
        'static/src/js/controllers.js'
      ])
    )
    .pipe(concat('app.js'))
    .pipe(gulp.dest('static/dist/js/'))
})

const stream = merge2([stream1, stream2], stream3, {end: false})
//...
stream.add(stream4, stream5)
//..
stream.end()

// equal to merge2([stream1, stream2], stream3)
const stream = merge2()
stream.add([stream1, stream2])
stream.add(stream3)

// merge order:
//   1. merge `stream1`;
//   2. merge `stream2` and `stream3` in parallel after `stream1` merged;
//   3. merge 'stream4' after `stream2` and `stream3` merged;
const stream = merge2(stream1, [stream2, stream3], stream4)

// merge order:
//   1. merge `stream5` and `stream6` in parallel after `stream4` merged;
//   2. merge 'stream7' after `stream5` and `stream6` merged;
stream.add([stream5, stream6], stream7)

// nest merge
// equal to merge2(stream1, stream2, stream6, stream3, [stream4, stream5]);
const streamA = merge2(stream1, stream2)
const streamB = merge2(stream3, [stream4, stream5])
const stream = merge2(streamA, streamB)
streamA.add(stream6)

API 密码

const merge2 = require('merge2')

合并2 ()

合并( 选项)

合并( sream1, stream2,..., streamN) :

合并2( stream1, stream2,..., streamN, 选项)

合并2( stream 1, [ stream 2, stream3,.], streamN, 选项)

返回双相流( 已合并的 Stream)。 阵列中的流将平行合并.

合并 Stream.add( 流)

合并了 Stream.add( stream 1, [ stream2, stream3,...],...)

返回合并的 Stream .

已合并 Stream.on ('queueDrain', 函数 () QQ)

当所有溪流合并时,它会发出"排出"(queueDrain). 如果你准备好了 end === false 在选项中,此事件会给您一个通知,该通知应该添加更多的流来合并或结束合并的Stream.

流线

选项 类型 : Readable 或者说 Duplex 或者说 Transform 流线.

选项

选项 类型 : Object。 。 。 .

• 结束 - 说吧 Boolean - 狦 end === false 然后合并Stream不会自动结束 你应该自己结束. 默认 : undefined

• 管道错误 - 说吧 Boolean - 狦 pipeError === true 然后合并 Stream 会发射 error 来自源流的事件. 默认 : undefined

• 对象模式 - 说吧 Boolean 。 。 。 . 默认 : true

objectMode 和其他选项(highWaterMark, (中文(简体) ), defaultEncoding ...)与节点.js相同 Stream。 。 。 .

许可证

麻省理工学院 团队