如何在 C# 中将流代码转换为 observable(reactive)？答案

【问题标题】：How to convert stream code to observable(reactive) in c#?如何在 C# 中将流代码转换为 observable(reactive)？
【发布时间】：2020-07-08 06:51:03
【问题描述】：

我有这个代码并且它有效。如何将此代码转换为reactive programming 代码？此代码与grpc server 一起使用，将流文件发送到grpc server 并在消息中获取操作结果

foreach (var item in uploadedFiles)
{
    using (var call = client.TransferFiles(item))
    {
        while (await call.ResponseStream.MoveNext())
        {
            var currentFile = call.ResponseStream.Current;
            System.Diagnostics.Debug.WriteLine(currentFile .Message);
        }
    }
}

client.TransferFiles(item)在grpc服务器中实现

【问题讨论】：

标签： c# reactive-programming grpc

【解决方案1】：

您在 Rx 中的代码如下：

uploadedFiles.ToObservable().Subscribe(uploadedFile =>
            {
                var call = client.TransferFiles(uploadedFile);
                while (call.ResponseStream.MoveNext())
                {
                    var currentFile = call.ResponseStream.Current;
                    System.Diagnostics.Debug.WriteLine(currentFile.Message);
                }
            });

【讨论】：