GetBlobsAsyncCollection
using System.Runtime.CompilerServices;
using System.Threading;
using System.Threading.Tasks;
namespace Azure.Storage.Blobs.Models
{
internal class GetBlobsAsyncCollection : StorageCollectionEnumerator<BlobItem>
{
private readonly BlobContainerClient _client;
private readonly BlobTraits _traits;
private readonly BlobStates _states;
private readonly string _prefix;
public GetBlobsAsyncCollection(BlobContainerClient client, BlobTraits traits, BlobStates states, string prefix)
{
_client = client;
_traits = traits;
_states = states;
_prefix = prefix;
}
[AsyncStateMachine(typeof(<GetNextPageAsync>d__5))]
public override ValueTask<Page<BlobItem>> GetNextPageAsync(string continuationToken, int? pageSizeHint, bool async, CancellationToken cancellationToken)
{
<GetNextPageAsync>d__5 stateMachine = default(<GetNextPageAsync>d__5);
stateMachine.<>t__builder = AsyncValueTaskMethodBuilder<Page<BlobItem>>.Create();
stateMachine.<>4__this = this;
stateMachine.continuationToken = continuationToken;
stateMachine.pageSizeHint = pageSizeHint;
stateMachine.async = async;
stateMachine.cancellationToken = cancellationToken;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
}
}