如何从模块返回管道数据？

Question

我有一个过滤器功能，该功能可以通过其他几个过滤器的管道运行数据流。如何在管道末端返回数据？

// takes a stream and returns a stream
function fixdata(data_in) {
    data_in
    .pipe(fix_data_types)
    .pipe(choose_columns)
    .pipe(filter_bad_data)
    .pipe( return? ); 
}
module.exports = fixdata;

Answer 1

您的pipe函数返回数据，以便下一个函数可以使用它。因此，您所需要的只是返回它：

function fixdata(data_in) {
  return data_in
    .pipe(fix_data_types)
    .pipe(choose_columns)
    .pipe(filter_bad_data); 
}