HBaseClient.CreateScannerAsync decompiled

CreateScannerAsync.cs

using Microsoft.HBase.Client;
using Microsoft.HBase.Client.Internal;
using org.apache.hadoop.hbase.rest.protobuf.generated;
using System;
using System.Diagnostics;
using System.Runtime.CompilerServices;
using System.Threading.Tasks;

[CompilerGenerated]
private sealed class <CreateScannerAsync>d__9 : IAsyncStateMachine
{
	public int <>1__state;

	public AsyncTaskMethodBuilder<ScannerInformation> <>t__builder;

	public string tableName;

	public Scanner scannerSettings;

	public RequestOptions options;

	public HBaseClient <>4__this;

	private HBaseClient.<>c__DisplayClass9_0 <>8__1;

	private ScannerInformation <>s__2;

	private TaskAwaiter<ScannerInformation> <>u__1;

	void IAsyncStateMachine.MoveNext()
	{
		int num = this.<>1__state;
		ScannerInformation result2;
		try
		{
			TaskAwaiter<ScannerInformation> taskAwaiter;
			if (num != 0)
			{
				this.<>8__1 = new HBaseClient.<>c__DisplayClass9_0();
				this.<>8__1.<>4__this = this.<>4__this;
				this.<>8__1.tableName = this.tableName;
				this.<>8__1.scannerSettings = this.scannerSettings;
				this.<>8__1.options = this.options;
				this.<>8__1.tableName.ArgumentNotNullNorEmpty("tableName");
				this.<>8__1.scannerSettings.ArgumentNotNull("scannerSettings");
				this.<>8__1.options.ArgumentNotNull("options");
				taskAwaiter = this.<>8__1.options.RetryPolicy.ExecuteAsync<ScannerInformation>(new Func<Task<ScannerInformation>>(this.<>8__1.<CreateScannerAsync>b__0)).GetAwaiter();
				if (!taskAwaiter.IsCompleted)
				{
					this.<>1__state = 0;
					this.<>u__1 = taskAwaiter;
					HBaseClient.<CreateScannerAsync>d__9 <CreateScannerAsync>d__ = this;
					this.<>t__builder.AwaitUnsafeOnCompleted<TaskAwaiter<ScannerInformation>, HBaseClient.<CreateScannerAsync>d__9>(ref taskAwaiter, ref <CreateScannerAsync>d__);
					return;
				}
			}
			else
			{
				taskAwaiter = this.<>u__1;
				this.<>u__1 = default(TaskAwaiter<ScannerInformation>);
				this.<>1__state = -1;
			}
			ScannerInformation result = taskAwaiter.GetResult();
			taskAwaiter = default(TaskAwaiter<ScannerInformation>);
			this.<>s__2 = result;
			result2 = this.<>s__2;
		}
		catch (Exception exception)
		{
			this.<>1__state = -2;
			this.<>t__builder.SetException(exception);
			return;
		}
		this.<>1__state = -2;
		this.<>t__builder.SetResult(result2);
	}

	[DebuggerHidden]
	void IAsyncStateMachine.SetStateMachine(IAsyncStateMachine stateMachine)
	{
	}
}