FromAsyncImpl() [1/2]

static Task< TResult > System.Threading.Tasks.TaskFactory< TResult >.FromAsyncImpl ( Func< AsyncCallback, object, IAsyncResult > beginMethod, Func< IAsyncResult, TResult > endFunction, Action< IAsyncResult > endAction, object state, TaskCreationOptions creationOptions )

inlinestaticpackage

Definition at line 322 of file TaskFactory.cs.

    {
        if (beginMethod == null)
        {
            ThrowHelper.ThrowArgumentNullException(ExceptionArgument.beginMethod);
        }
        if (endFunction == null && endAction == null)
        {
            ThrowHelper.ThrowArgumentNullException(ExceptionArgument.endMethod);
        }
        TaskFactory.CheckFromAsyncOptions(creationOptions, hasBeginMethod: true);
        Task<TResult> promise = new Task<TResult>(state, creationOptions);
        if (TplEventSource.Log.IsEnabled())
        {
            TplEventSource.Log.TraceOperationBegin(promise.Id, "TaskFactory.FromAsync: " + beginMethod.Method.Name, 0L);
        }
        if (Task.s_asyncDebuggingEnabled)
        {
            Task.AddToActiveTasks(promise);
        }
        try
        {
            IAsyncResult asyncResult = beginMethod(delegate(IAsyncResult iar)
            {
                if (!iar.CompletedSynchronously)
                {
                    FromAsyncCoreLogic(iar, endFunction, endAction, promise, requiresSynchronization: true);
                }
            }, state);
            if (asyncResult.CompletedSynchronously)
            {
                FromAsyncCoreLogic(asyncResult, endFunction, endAction, promise, requiresSynchronization: false);
            }
        }
        catch
        {
            if (TplEventSource.Log.IsEnabled())
            {
                TplEventSource.Log.TraceOperationEnd(promise.Id, AsyncCausalityStatus.Error);
            }
            if (Task.s_asyncDebuggingEnabled)
            {
                Task.RemoveFromActiveTasks(promise);
            }
            promise.TrySetResult();
            throw;
        }
        return promise;
    }

References System.Threading.Tasks.Task< TResult >.AddToActiveTasks(), System.asyncResult, System.beginMethod, System.Threading.Tasks.TaskFactory< TResult >.CheckFromAsyncOptions(), System.creationOptions, System.endFunction, System.Threading.Tasks.TplEventSource.Log, System.Threading.Tasks.Task< TResult >.RemoveFromActiveTasks(), System.Threading.Tasks.Task< TResult >.s_asyncDebuggingEnabled, System.state, and System.ThrowHelper.ThrowArgumentNullException().