C#并发编程经典实例（第2版）

100

｜

第

8

章

}

catch

(Exception ex)

{

block.Fault(ex);

}

}

讨论

本节只给出了浅层的介绍，尤其要注意，

WriteToBlockAsync

扩展方法会做一些假设。请务

必考虑这些方法的行为，另外在使用之前，确保它们的行为适用于你的场景。

参阅

3.8

节探讨如何处理异步流的取消操作。

第

5

章探讨用于

TPL

数据流的方法。

9.8

节探讨将通道作为异步流来消耗。

8.8

　

System.Reactive

可观察对象和数据流网格

问题

假设有一部分解决方案使用了

System.Reactive

可观察对象，另一部分使用了数据流网格，

现在需要让两者交互。

System.Reactive

可观察对象与数据流网格各有千秋，但在概念方面不乏一些交集。本节会

展现它们协同工作的易用性，这样便能针对工作的每一部分采用最佳的工具。

解决方案

考虑把数据流块用作可观察流的输入。下面的示例代码创建了缓冲块（该块并不执行处

理），然后通过调用

AsObservable

从该块创建了可观察接口：

var

buffer =

new

BufferBlock<

int

>();

IObservable<

int

> integers = buffer.AsObservable();

integers.Subscribe(data => Trace.WriteLine(data),

ex => Trace.WriteLine(ex),

() => Trace.WriteLine(

"

Done"));

buffer.Post(13); ...