Rx.Net:如何同时读取不同线程上的所有文件

using System;
using System.IO;
using System.Reactive.Linq;
using System.Threading.Tasks;

public class Program
{
    public static async Task Main()
    {
        var file1 = ReadFileAsync("file1.txt");
        var file2 = ReadFileAsync("file2.txt");
        var file3 = ReadFileAsync("file3.txt");

        var observable = Observable.Merge(file1, file2, file3);

        using (observable.Subscribe(fileData =>
        {
            // 处理读取到的文件数据
            Console.WriteLine(fileData);
        }))
        {
            // 等待所有文件读取完成
            await Task.WhenAll(file1, file2, file3);
        }
    }

    private static async Task<string> ReadFileAsync(string filePath)
    {
        using (var reader = new StreamReader(filePath))
        {
            return await reader.ReadToEndAsync();
        }
    }
}