Как вы возвращаете данные из модуля?

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); 
}