2

我想知道为什么这个代码IAsyncEnumerable<>

dynamic duckAsyncEnumerable = new int[0].ToAsyncEnumerable();
var duckAsyncEnumerator = duckAsyncEnumerable.GetEnumerator();

引发异常：

“object”不包含“GetEnumerator”的定义

相同的代码可以IEnumerable<>正常工作。此外，IAsyncEnumerable<>通过反射的实现也可以正常工作。在 .NET 和 .NET Core 中重现。

IOutputFormatter实现将源数据作为对象并必须遍历它所需的代码。

dotnetfiddle 中描述的示例

4

2 回答 2

2

调用new int[0].ToAsyncEnumerable()将返回（内部）类型AsyncIListEnumerableAdapter<int>。这种类型实现了除其他外IEnumerable<int>，因此它具有方法IEnumerable<int>.GetEnumerator()。但是，它使用显式接口实现来实现此方法。

显式实现的接口方法在调用时不可用dynamic（它是私有的）。要访问该方法，您必须首先转换对接口的引用，如对问题使用显式接口实现与动态对象的回答中所述。

于 2017-09-08T09:51:34.820 回答
0

我得到了解决方案。ToAsyncEnumerable一个对象具有返回的扩展方法IAsyncEnumerable<object>。因此我们可以迭代它：

public async Task Process(object source)
{
    using (var enumerator = source.ToAsyncEnumerable().GetEnumerator())
    {
        while (await enumerator.MoveNext())
        {
            var item = enumerator.Current;
        }
    }
}

可以创建一个接受IAsyncEnumerable<T>和实现的包装器IAsyncEnumerable<object>。Activator在扩展方法中创建该包装器。这是实现：

public class AsyncEnumerable<T> : IAsyncEnumerable<object>
{
    private IAsyncEnumerable<T> _source;

    public AsyncEnumerable(IAsyncEnumerable<T> source)
    {
        _source = source;
    }

    public IAsyncEnumerator<object> GetEnumerator()
    {
        return new AsyncEnumerator<T>(_source.GetEnumerator());
    }
}

public class AsyncEnumerator<T> : IAsyncEnumerator<object>
{
    private IAsyncEnumerator<T> _source;

    public AsyncEnumerator(IAsyncEnumerator<T> source)
    {
        _source = source;
    }

    public object Current => _source.Current;

    public void Dispose()
    {
        _source.Dispose();
    }

    public async Task<bool> MoveNext(CancellationToken cancellationToken)
    {
        return await _source.MoveNext(cancellationToken);      
    }
}

public static class AsyncEnumerationExtensions
{
    public static IAsyncEnumerable<object> ToAsyncEnumerable(this object source)
    {
        if (source == null)
        {
            throw new ArgumentNullException(nameof(source));
        }
        else if (!source.GetType().GetInterfaces().Any(i => i.GetGenericTypeDefinition() == typeof(IAsyncEnumerable<>)))
        {
            throw new ArgumentException("IAsyncEnumerable<> expected", nameof(source));
        }            

        var dataType = source.GetType()
            .GetInterfaces()
            .First(i => i.GetGenericTypeDefinition() == typeof(IAsyncEnumerable<>))
            .GetGenericArguments()[0];

        var collectionType = typeof(AsyncEnumerable<>).MakeGenericType(dataType);

        return (IAsyncEnumerable<object>)Activator.CreateInstance(collectionType, source);
    }
}
于 2017-09-08T14:22:25.423 回答