0 
async Task<packet> getMyPacket()
 {   
    IObservable<packet> packets = ...;
        await packets
                 .Where(x => x.frameType == CMD_ID_0 )
                 .FirstAsync()
                 .GetAwaiter()
                 ;

  }

上面的代码片段工作正常。

但是，如何使用 GetAwaiter 完成错误处理？

例如，如果它应该返回标准错误数据包，则超时。

await packets
         .Where(x => x.frameType == CMD_ID_0 )
         .FirstAsync()
         .TimeOut( TimeSpan.FromSeconds(5))
         .GetAwaiter (   , ,OnError: return newErrorPacket(TIMEOUT) ) 
         ;

我曾尝试查看可用的文档，但未能走得更远。我不熟悉将 async/Tasks 与 IObservable 相结合，所以我有一个概念错误，请告诉我。

4

2 回答 2

1

处理异常的一种可能方法是使用该ContinueWith方法，如下面的代码示例所示（我使用了一些虚拟类和枚举来使代码正常工作，您可以将它们替换为您自己现有的类和枚举）。

using System;
using System.Collections.Generic;
using System.Collections;

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

class Program
{
    public static void Main()
    {
        var packets = getMyPacket().ContinueWith((a) =>
        {
            Packet packet = null;
            if (a.Exception != null && a.Exception.InnerException.GetType() == typeof(TimeoutException))
            {
                packet = new ErrorPacket(Error.TIMEOUT);
            }
            else
            {
                packet = a.Result;
            }
            return packet;
        });

        Console.ReadLine();
        Console.WriteLine(packets.Result.GetType());
    }

    static async Task<Packet> getMyPacket()
    {
        var list = new List<Packet>();
        list.Add(new Packet(FrameType.CMD_ID_0));

        IObservable<Packet> packets = list.ToObservable();
        var aw = await packets
                 .Where(x => x.FrameType == FrameType.CMD_ID_0)
                 .FirstAsync()
                 //.Timeout(TimeSpan.FromSeconds(0))
                 .GetAwaiter();

        return aw;

    }
    class Packet
    {
        public FrameType FrameType { get; set; }
        public Packet() 
        {
        }
        public Packet(FrameType frameType)
        {
            FrameType = frameType;
        }
    }
    class ErrorPacket : Packet
    {
        public ErrorPacket(Error error)
        {
        }
    }

    enum FrameType
    {
        CMD_ID_0,
        CMD_ID_1
    }

    enum Error
    {
        TIMEOUT
    }
}
于 2013-01-10T12:19:56.727 回答
0

IObservable 有一个 'Catch' 扩展方法来完成这项工作。

await packets
         .Where(x => x.frameType == CMD_ID_0 )       
         .TimeOut( TimeSpan.FromSeconds(5))
         .Catch( Observable.Empty<packet>())
         .LastOrDefaultAsync();

以上等待适当的响应数据包或超时。await 使用 GetAwaiter 在空序列上引发异常，因此 LastOrDefaultAsync() 有助于避免这种情况。或者，在 try-catch 之间封闭也可以。

于 2013-02-22T09:53:04.070 回答