Observable.FromAsyncPattern和UdpClient C＃

Question

我希望能够使用反应式异步接收udp软件包。我已经写了这段代码。udpServer = new UdpClient(20000);remoteEP = new IPEndPoint(IPAddress.Any, 20000);var read = Observable.FromAsyncPattern(udpServer.BeginReceive, t => udpServer.EndReceive(t, ref remoteEP));然后我使用此函数并存储IObservable结果。reader = read()       .Do(s =>       {           Logs.Add(System.Text.Encoding.UTF8.GetString(s));       })       .DoOnError(ex => status = ex.Message; );当我最终订阅时，该操作仅发生一次，然后观察者将被完全处置。这是我的问题：有没有办法使此代码连续工作？每次接收到新日志时如何接收“ DO”操作？侧边栏：只是想知道Observable.FromAsyncPattern有什么用处，如果我不能重用它，那么最好在开始和结束时静态键入2个方法，而不是让更多需要稍后处理的类实例产生开销。除使用TPL之外，-im还为其他所有其他选项打开。

Answer 1

试试这个：

var query =

    Observable

        .Using(

            () => new UdpClient(new IPEndPoint(IPAddress.Any, 20000)),

            udpServer =>

                Observable

                    .Defer(() =>

                        Observable

                            .FromAsync(() => udpServer.ReceiveAsync()))

                    .Repeat());

您需要使用来管理IDispose资源，.Using并且需要.Repeat致电FromAsync。

的FromAsyncPattern是现在已经过时。

如果您需要使用过时的方法，FromAsyncPattern请执行以下操作：

var query =

    Observable

        .Using(

            () => new UdpClient(20000),

            udpServer =>

                Observable

                    .Defer(() =>

                        Observable

                            .FromAsyncPattern(udpServer.BeginReceive, t => udpServer.EndReceive(t, ref remoteEP)))

                    .Repeat());

Answer 2

这是因为观察者在给定的集合上工作。从返回的集合BeginReceive不同于再次调用它。使用您显示的代码，我并不惊讶它只能运行一次。您需要提供一个一致的缓冲区BeginReceive，然后向该缓冲区预订观察者，因为它每次都会触发。也就是说，缓冲区在两次调用之间必须是相同的实例。