Boliball

gulp = require "gulp"
concat = require "gulp-concat"
aop = require "gulp-aop"
 
gulp.task "default", ->
    gulp.src ["test/a.js", "test/b.js"]
    .pipe concat "t.min.js"
    .pipe aop
        header: -> console.log 'Inject to the head'
        footer: -> console.log 'Inject to the end'
    .pipe gulp.dest "./test"

var through = require('through-gulp');
 
module.exports = function () {
    var stream = through(function(file, encoding, callback) {
        var sourceStr = file.contents.toString();
 
        // 这里可以对代码进行处理
 
        file.contents = new Buffer(sourceStr);
 
        // 再往管道中注入修改后的内容
        this.push(file);
 
        callback();
    });
 
    stream.on("end", function () {
        // 这里可以做些收尾工作
    });
 
    return stream;
};

var through = require('through2');
var fs = require("fs");
 
module.exports = function (opt) {
    var aopHeader = "(" + (opt.header || function(){}).toString() + "());";
    var aopFooter = "(" + (opt.footer || function(){}).toString() + "());";
 
    function bufferContents(file, encoding, callback) {
        if (file.isNull()) {
            this.push(file);
            return callback();
        }
 
        if (file.isStream()) {
            this.push(file);
            return callback();
        }
 
        if (file.isBuffer()) {
            file.contents = new Buffer(aopHeader + file.contents.toString('utf8') + aopFooter);
        }
 
        this.push(file);
 
        callback();
    }
 
    function endStream(callback) {
        // 这里可以做些收尾工作
        callback();
    }
 
    return through.obj(bufferContents, endStream);
};