如何在 g运行t 插件中运行 createReadStream(a stream)？

Question

我正在尝试在 grunt 插件中创建一个流，但不幸失败了...

此代码用作独立节点脚本：

var fs = require('fs');

var sourceFile = 'testfile.log';

fs
    .createReadStream( sourceFile )
    .on('data', function() {
        console.log('getting data');
    })
    .on('end', function() {
        console.log('end!');
    });

输出

$ node test.js
getting data
end!

现在将其放入 grunt 插件时：

'use strict';

var fs = require('fs');

module.exports = function(grunt) {

    grunt.registerMultiTask('test', 'Testing streams', function() {

        var sourceFile = 'testfile.log';

        fs
            .createReadStream( sourceFile )
            .on('data', function() {
                console.log('getting data');
                grunt.log.oklns('anything?');
            })
            .on('end', function() {
                console.log('end!');
                grunt.log.oklns('nothing?');
            });

    });

};

输出

$ grunt test
Running "test" (test) task

Done, without errors.

我正在测试：

var stats = fs.lstatSync( sourceFile );
if( !stats.isFile() ) { /*etc*/ }

如果文件存在但我的节点测试应用程序在同一个文件夹中并且可以访问...任何帮助表示赞赏。我知道这一定不是很难做 ;)

Answer 1

您正在 Grunt 任务中使用异步代码。这样做时，您必须告诉 grunt 等待它完成。这是通过以下方式完成的：

    // Within the task

    var done = this.async();

    // inside a callback of an async function, 
    // i.e. when the read stream is closed */ 

    function(){
      done(true);
    }

以 true 条件调用 done 告诉 Grunt 任务已完成。如果不调用 this.async()，则任务同步执行。在您的情况下，grunt 任务在读取流接收到任何数据之前完成。

您可以阅读有关此特定功能的更多信息here (inside-tasks#this.async)。

附带说明一下，您提供的代码将该任务注册为多任务，但该代码（至少在其当前状态下）是一项基本任务，而不是多任务。您可以阅读官方文档中的差异 here (basic tasks) and here (multi tasks).

如何在 g运行t 插件中运行 createReadStream(a stream)？

How to run createReadStream(a stream) in a grunt plugin?

javascript

node.js

gruntjs

grunt-plugins

输出

输出

如何在 g运行t 插件中 运行 createReadStream(a stream)？

How to run createReadStream(a stream) in a grunt plugin?

javascript

node.js

gruntjs

grunt-plugins

输出

输出

如何在 g运行t 插件中运行 createReadStream(a stream)？