如何从不同的函数发出值，但将所有值收集在一个地方？流水线

在软件开发中，将不同函数发出的值收集到一个地方，通常可以通过以下几种方式实现：

1. 使用回调函数（Callback）

回调函数是一种常见的异步编程模式，允许一个函数在完成其任务后调用另一个函数。

function fetchData(callback) {
    // 模拟异步操作
    setTimeout(() => {
        callback('Data from fetchData');
    }, 1000);
}

function processData(data, callback) {
    // 处理数据
    const processedData = data.toUpperCase();
    callback(processedData);
}

function collectData() {
    let collectedData = [];
    fetchData((data) => {
        processData(data, (processedData) => {
            collectedData.push(processedData);
            console.log(collectedData); // ['DATA FROM FETCHDATA']
        });
    });
}

collectData();

2. 使用Promise

Promise 是一种更现代的异步编程方式，可以更方便地处理异步操作的结果。

function fetchData() {
    return new Promise((resolve) => {
        setTimeout(() => {
            resolve('Data from fetchData');
        }, 1000);
    });
}

function processData(data) {
    return new Promise((resolve) => {
        const processedData = data.toUpperCase();
        resolve(processedData);
    });
}

async function collectData() {
    let collectedData = [];
    const data = await fetchData();
    const processedData = await processData(data);
    collectedData.push(processedData);
    console.log(collectedData); // ['DATA FROM FETCHDATA']
}

collectData();

3. 使用事件总线（Event Bus）

事件总线是一种发布-订阅模式，允许不同的组件或函数通过事件进行通信。

class EventBus {
    constructor() {
        this.listeners = {};
    }

    on(event, callback) {
        if (!this.listeners[event]) {
            this.listeners[event] = [];
        }
        this.listeners[event].push(callback);
    }

    emit(event, data) {
        if (this.listeners[event]) {
            this.listeners[event].forEach(callback => callback(data));
        }
    }
}

const eventBus = new EventBus();

eventBus.on('fetchData', (data) => {
    console.log('Fetch Data:', data);
});

eventBus.on('processData', (data) => {
    console.log('Process Data:', data);
});

function fetchData() {
    setTimeout(() => {
        eventBus.emit('fetchData', 'Data from fetchData');
    }, 1000);
}

function processData() {
    eventBus.emit('processData', 'Data from processData');
}

fetchData();
processData();

4. 使用流（Stream）

在处理大量数据或实时数据时，流是一种非常有效的方式。Node.js 中的 Stream API 可以方便地处理数据流。

const { Readable, Writable } = require('stream');

const readableStream = new Readable({
    read() {}
});

const writableStream = new Writable({
    write(chunk, encoding, callback) {
        console.log('Collected Data:', chunk.toString());
        callback();
    }
});

readableStream.push('Data from fetchData\n');
readableStream.push('Data from processData\n');
readableStream.push(null); // 结束流

readableStream.pipe(writableStream);