PromiseHelpers.cs
95 lines
| 4.4 KiB
| text/x-csharp
|
CSharpLexer
/ Implab.Fx / PromiseHelpers.cs
cin
|
r4 | using System; | ||
| using System.Collections.Generic; | ||||
| using System.Linq; | ||||
| using System.Text; | ||||
| using System.Windows.Forms; | ||||
| using System.Threading; | ||||
| namespace Implab.Fx | ||||
| { | ||||
| public static class PromiseHelpers | ||||
| { | ||||
| /// <summary> | ||||
| /// Перенаправляет обработку обещания в поток указанного элемента управления. | ||||
| /// </summary> | ||||
| /// <typeparam name="T">Тип результата обещания</typeparam> | ||||
| /// <param name="that">Исходное обещание</param> | ||||
| /// <param name="ctl">Элемент управления</param> | ||||
| /// <returns>Новое обещание, обработчики которого будут выполнены в потоке элемента управления.</returns> | ||||
| /// <exception cref="ArgumentNullException">Параметр не может быть <c>null</c>.</exception> | ||||
| /// <example> | ||||
| /// client | ||||
| /// .Get("description.txt") // returns a promise | ||||
| /// .DirectToControl(m_ctl) // handle the promise in the thread of the control | ||||
| /// .Then( | ||||
| /// description => m_ctl.Text = description // now it's safe | ||||
| /// ) | ||||
| /// </example> | ||||
|
cin
|
r111 | public static Promise<T> DispatchToControl<T>(this IPromise<T> that, Control ctl) | ||
|
cin
|
r4 | { | ||
| if (that == null) | ||||
| throw new ArgumentNullException("that"); | ||||
| if (ctl == null) | ||||
| throw new ArgumentNullException("ctl"); | ||||
| var directed = new Promise<T>(); | ||||
| that.Then( | ||||
| res => | ||||
| { | ||||
| if (ctl.InvokeRequired) | ||||
| ctl.Invoke(new Action<T>(directed.Resolve), res); | ||||
| else | ||||
| directed.Resolve(res); | ||||
| }, | ||||
| err => | ||||
| { | ||||
| if (ctl.InvokeRequired) | ||||
| ctl.Invoke(new Action<Exception>(directed.Reject), err); | ||||
| else | ||||
| directed.Reject(err); | ||||
| } | ||||
| ); | ||||
| return directed; | ||||
| } | ||||
| /// <summary> | ||||
| /// Направляет обработку обещания в текущий поток, если у него существует контекст синхронизации. | ||||
| /// </summary> | ||||
| /// <typeparam name="T">Тип результата обещания.</typeparam> | ||||
| /// <param name="that">Обещание которое нужно обработать в текущем потоке.</param> | ||||
| /// <returns>Перенаправленное обещание.</returns> | ||||
| public static Promise<T> DispatchToCurrentThread<T>(this Promise<T> that) | ||||
| { | ||||
| var sync = SynchronizationContext.Current; | ||||
| if (sync == null) | ||||
| throw new InvalidOperationException("The current thread doesn't have a syncronization context"); | ||||
| return DispatchToSyncContext(that, sync); | ||||
| } | ||||
| /// <summary> | ||||
| /// Направляет обработку обещания в указанный контекст синхронизации. | ||||
| /// </summary> | ||||
| /// <typeparam name="T">Тип результата обещания.</typeparam> | ||||
| /// <param name="that">Обещание, которое требуется обработать в указанном контексте синхронизации.</param> | ||||
| /// <param name="sync">Контекст синхронизации в который будет направлено обещание.</param> | ||||
| /// <returns>Новое обещание, которое будет обрабатываться в указанном контексте.</returns> | ||||
| public static Promise<T> DispatchToSyncContext<T>(this Promise<T> that, SynchronizationContext sync) | ||||
| { | ||||
| if (that == null) | ||||
| throw new ArgumentNullException("that"); | ||||
| if (sync == null) | ||||
| throw new ArgumentNullException("sync"); | ||||
| var d = new Promise<T>(); | ||||
| that.Then( | ||||
| res => sync.Post(state => d.Resolve(res), null), | ||||
| err => sync.Post(state => d.Reject(err), null) | ||||
| ); | ||||
| return d; | ||||
| } | ||||
| } | ||||
| } | ||||