view Implab/ActionChainTask.cs @ 185:822aab37b107 ref20160224

runnable component, work in progress
author cin
date Mon, 18 Apr 2016 16:41:17 +0300
parents eb793fbbe4ea
children dd4a3590f9c6
line wrap: on
line source

using System;

namespace Implab {
    public class ActionChainTask : ActionChainTaskBase, IDeferred {
        readonly Func<IPromise> m_task;

        /// <summary>
        /// Initializes a new instance of the <see cref="Implab.ActionChainTask"/> class.
        /// </summary>
        /// <param name="task">The operation which will be performed when the <see cref="Resolve()"/> is called.</param>
        /// <param name="error">The error handler which will invoke when the <see cref="Reject(Exception)"/> is called or when the task fails with an error.</param>
        /// <param name="cancel">The cancellation handler.</param>
        /// <param name="autoCancellable">If set to <c>true</c> will automatically accept
        ///  all cancel requests before the task is started with <see cref="Resolve()"/>,
        /// after that all requests are directed to the task.</param>
        public ActionChainTask(Func<IPromise> task, Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) : base(error,cancel, autoCancellable) {
            m_task = task;
        }

        public void Resolve() {
            if (m_task != null && LockCancelation()) {
                try {
                    var p = m_task();
                    p.On(SetResult, HandleErrorInternal, SetCancelled);
                    CancellationRequested(p.Cancel);
                } catch(Exception err) {
                    HandleErrorInternal(err);
                }
            }
        }

    }
}