Альтернатива сдаче в IAsyncEnumerable - PullRequest
Новая
       11

Альтернатива сдаче в IAsyncEnumerable

0 голосов
/ 06 июля 2019

Я пытаюсь получить данные, разбитые на страницы, используя новые AsyncEnumerables в C # 8.0.В синхронном мире IEnumerable код выглядел бы примерно так: 

private IEnumerable<S3Object> Example(S3FilesRequest requestData)
    {
        var request = new ListObjectsV2Request()
        {
            BucketName = requestData.Bucket,
            Prefix = requestData.KeyPrefix
        };

        ListObjectsV2Response response;
        do
        {
            response = this.client.ListObjectsV2Async(request).Result;
            foreach (var s3Obj in response.S3Objects)
                yield return s3Obj;
            request.ContinuationToken = response.NextContinuationToken;
        } while (response.IsTruncated);
    }
    // Not tested - can probably be more succinct (using TakeWhile and SelectMany) but you get the idea

Использование IAsyncEnumerable Я думаю, что это выглядело бы примерно так: 

private IAsyncEnumerable<S3Object> listObjects(S3FilesRequest requestData)
        => AsyncEnumerable.CreateEnumerable(() =>
        {
            var request = new ListObjectsV2Request()
            {
                BucketName = requestData.Bucket,
                Prefix = requestData.KeyPrefix
            };
            ListObjectsV2Response response = null;
            List<S3Object>.Enumerator enumerator = default;
            S3Object current = null;
            bool movedNext = false;

            return AsyncEnumerable.CreateEnumerator<S3Object>(async c =>
            {
                if (response == null || !movedNext)
                {
                    enumerator.Dispose();
                    response = await this.client.ListObjectsV2Async(request, c);
                    enumerator = response.S3Objects.GetEnumerator();
                }

                movedNext = enumerator.MoveNext();
                current = enumerator.Current;

                request.ContinuationToken = response.NextContinuationToken;
                return movedNext || response.IsTruncated;
            }, () => current, enumerator.Dispose);
        });

Кажется, это немного затянуто, но без ключевого слова yield есть лучший способ?

Спасибо,

Джо

РЕДАКТИРОВАТЬ:

Это было вызвано установкой ReSharper без вывода сообщенийSystem.Interactive.Async при обновлении до C # 8. Я удалил его и последовал совету Стивена.

Для Google: 

CS0518  Predefined type 'System.Runtime.CompilerServices.AsyncIteratorMethodBuilder' is not defined or imported
CS0656  Missing compiler required member 'System.Runtime.CompilerServices.AsyncIteratorMethodBuilder.Create'
CS0656  Missing compiler required member 'System.Collections.Generic.IAsyncEnumerable`1.GetAsyncEnumerator'
CS0656  Missing compiler required member 'System.Collections.Generic.IAsyncEnumerator`1.MoveNextAsync'
CS0656  Missing compiler required member 'System.IAsyncDisposable.DisposeAsync'
CS0656  Missing compiler required member 'System.Threading.Tasks.ValueTask`1..ctor' 
CS0656  Missing compiler required member 'System.Threading.Tasks.ValueTask..ctor'
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.ManualResetValueTaskSourceCore`1.GetResult'cs
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.ManualResetValueTaskSourceCore`1.GetStatus'cs
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.ManualResetValueTaskSourceCore`1.get_Version'cs 
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.ManualResetValueTaskSourceCore`1.OnCompleted'cs
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.ManualResetValueTaskSourceCore`1.Reset' 
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.ManualResetValueTaskSourceCore`1.SetExceptioncs 
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.ManualResetValueTaskSourceCore`1.SetResult'cs 
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.IValueTaskSource`1.GetResult' 
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.IValueTaskSource`1.GetStatus' 
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.IValueTaskSource`1.OnCompleted'
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.IValueTaskSource.GetResult' 
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.IValueTaskSource.GetStatus' 
CS0656  Missing compiler required member 'System.Threading.Tasks.Sources.IValueTaskSource.OnCompleted'

1 Ответ

2 голосов
/ 06 июля 2019

Если вы используете C # 8.0, то вы можете использовать yield с async очень хорошо: 

private async IAsyncEnumerable<S3Object> Example(S3FilesRequest requestData)
{
  var request = new ListObjectsV2Request()
  {
    BucketName = requestData.Bucket,
    Prefix = requestData.KeyPrefix
  };

  ListObjectsV2Response response;
  do
  {
    response = await this.client.ListObjectsV2Async(request);
    foreach (var s3Obj in response.S3Objects)
      yield return s3Obj;
    request.ContinuationToken = response.NextContinuationToken;
  } while (response.IsTruncated);
}

(а асинхронные методы LINQ, такие как TakeWhile и SelectMany, находятся вSystem.Linq.Async пакет )

...