implab/ImplabNet Commit - r72:d67b95eddaf4

promises refactoring

cin -

r72:d67b95eddaf4 v2

parent child

Context file:

r72:d67b95eddaf4

Collapse all files

Implab.Fx/ControlBoundPromise.cs created 644 +30 0

@@ -0,0 +1,30
	1	using System.Windows.Forms;
	2	using System;
	3
	4
	5	namespace Implab.Fx {
	6	public class ControlBoundPromise<T> : Promise<T> {
	7	readonly Control m_target;
	8
	9	public ControlBoundPromise(Control target) {
	10	Safe.ArgumentNotNull(target, "target");
	11
	12	m_target = target;
	13	}
	14
	15	public ControlBoundPromise(Control target, IPromise parent, bool cancellable)
	16	: base(parent, cancellable) {
	17	Safe.ArgumentNotNull(target, "target");
	18
	19	m_target = target;
	20	}
	21
	22	protected override void InvokeHandler(HandlerDescriptor handler) {
	23	if (m_target.InvokeRequired)
	24	m_target.BeginInvoke(new Action<HandlerDescriptor>(base.InvokeHandler), handler);
	25	else
	26	base.InvokeHandler(handler);
	27	}
	28	}
	29	}
	30

Implab/PromiseExtensions.cs created 644 +38 0

@@ -0,0 +1,38
	1	using System.Threading;
	2
	3	namespace Implab {
	4	public static class PromiseExtensions {
	5	public static IPromise<T> DispatchToCurrentContext<T>(this IPromise<T> that) {
	6	var context = SynchronizationContext.Current;
	7	if (context == null)
	8	return that;
	9
	10	var p = new SyncContextPromise<T>(context, that, true);
	11
	12	that.Then(
	13	x => p.Resolve(x),
	14	e => {
	15	p.Reject(e);
	16	return default(T);
	17	}
	18	);
	19	return p;
	20	}
	21
	22	public static IPromise<T> DispatchToContext<T>(this IPromise<T> that, SynchronizationContext context) {
	23	Safe.ArgumentNotNull(context, "context");
	24
	25	var p = new SyncContextPromise<T>(context, that, true);
	26
	27	that.Then(
	28	x => p.Resolve(x),
	29	e => {
	30	p.Reject(e);
	31	return default(T);
	32	}
	33	);
	34	return p;
	35	}
	36	}
	37	}
	38

Implab/SyncContextPromise.cs created 644 +22 0

@@ -0,0 +1,22
	1	using System.Threading;
	2
	3	namespace Implab {
	4	public class SyncContextPromise<T> : Promise<T> {
	5	readonly SynchronizationContext m_context;
	6
	7	public SyncContextPromise(SynchronizationContext context) {
	8	Safe.ArgumentNotNull(context, "context");
	9	m_context = context;
	10	}
	11
	12	public SyncContextPromise(SynchronizationContext context, IPromise parent, bool cancellable)
	13	: base(parent, cancellable) {
	14	Safe.ArgumentNotNull(context, "context");
	15	m_context = context;
	16	}
	17	protected override void InvokeHandler(HandlerDescriptor handler) {
	18	m_context.Post(x => base.InvokeHandler(handler),null);
	19	}
	20	}
	21	}
	22

Implab/TransientPromiseException.cs created 644 +33 0

@@ -0,0 +1,33
	1	using System;
	2
	3	namespace Implab {
	4
	5	[Serializable]
	6	public class TransientPromiseException : Exception {
	7	/// <summary>
	8	/// Initializes a new instance of the <see cref="PromiseFailedException"/> class.
	9	/// </summary>
	10	/// <param name="inner">The exception that is the cause of the current exception.</param>
	11	public TransientPromiseException(Exception inner) : base("The preceding promise has failed", inner) {
	12	}
	13
	14	/// <summary>
	15	/// Initializes a new instance of the <see cref="PromiseFailedException"/> class
	16	/// </summary>
	17	/// <param name="message">A <see cref="T:System.String"/> that describes the exception. </param>
	18	/// <param name="inner">The exception that is the cause of the current exception. </param>
	19	public TransientPromiseException(string message, Exception inner)
	20	: base(message, inner) {
	21	}
	22
	23	/// <summary>
	24	/// Initializes a new instance of the <see cref="PromiseFailedException"/> class
	25	/// </summary>
	26	/// <param name="context">The contextual information about the source or destination.</param>
	27	/// <param name="info">The object that holds the serialized object data.</param>
	28	protected TransientPromiseException(System.Runtime.Serialization.SerializationInfo info, System.Runtime.Serialization.StreamingContext context)
	29	: base(info, context) {
	30	}
	31	}
	32	}
	33

Implab.Fx.Test/Implab.Fx.Test.csproj +5 -7

             <?xml version="1.0" encoding="utf-8"?>
             <Project ToolsVersion="4.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
               <PropertyGroup>
                 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
                 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-                <ProductVersion>
+                <ProductVersion>8.0.30703</ProductVersion>
-                </ProductVersion>
                 <SchemaVersion>2.0</SchemaVersion>
                 <ProjectGuid>{2F31E405-E267-4195-A05D-574093C21209}</ProjectGuid>
                 <OutputType>Library</OutputType>
                 <AppDesignerFolder>Properties</AppDesignerFolder>
                 <RootNamespace>Implab.Fx.Test</RootNamespace>
                 <AssemblyName>Implab.Fx.Test</AssemblyName>
                 <TargetFrameworkVersion>v4.0</TargetFrameworkVersion>
                 <FileAlignment>512</FileAlignment>
                 <ProjectTypeGuids>{3AC096D0-A1C2-E12C-1390-A8335801FDAB};{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}</ProjectTypeGuids>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug\</OutputPath>
                 <DefineConstants>DEBUG;TRACE</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
                 <DebugType>pdbonly</DebugType>
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release\</OutputPath>
                 <DefineConstants>TRACE</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
               </PropertyGroup>
               <ItemGroup>
                 <Reference Include="Microsoft.VisualStudio.QualityTools.UnitTestFramework, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL" />
                 <Reference Include="System" />
                 <Reference Include="System.Core">
                   <RequiredTargetFramework>3.5</RequiredTargetFramework>
                 </Reference>
                 <Reference Include="System.Data" />
                 <Reference Include="System.Drawing" />
                 <Reference Include="System.Windows.Forms" />
                 <Reference Include="System.Xml" />
                 <Reference Include="WindowsBase" />
               </ItemGroup>
               <ItemGroup>
-                <CodeAnalysisDependentAssemblyPaths Condition=" '$(VS100COMNTOOLS)' != '' " Include="$(VS100COMNTOOLS)..\IDE\PrivateAssemblies">
-                  <Visible>False</Visible>
-                </CodeAnalysisDependentAssemblyPaths>
-              </ItemGroup>
-              <ItemGroup>
                 <Compile Include="Properties\AssemblyInfo.cs" />
                 <Compile Include="OverlayTest.cs" />
                 <Compile Include="Sample\MainForm.cs">
                   <SubType>Form</SubType>
                 </Compile>
                 <Compile Include="Sample\MainForm.Designer.cs">
                   <DependentUpon>MainForm.cs</DependentUpon>
                 </Compile>
                 <Compile Include="Sample\OverlayForm.cs">
                   <SubType>Form</SubType>
                 </Compile>
                 <Compile Include="Sample\OverlayForm.Designer.cs">
                   <DependentUpon>OverlayForm.cs</DependentUpon>
                 </Compile>
               </ItemGroup>
               <ItemGroup>
                 <EmbeddedResource Include="Sample\MainForm.resx">
                   <DependentUpon>MainForm.cs</DependentUpon>
+                  <LogicalName>
+                  </LogicalName>
                 </EmbeddedResource>
                 <EmbeddedResource Include="Sample\OverlayForm.resx">
                   <DependentUpon>OverlayForm.cs</DependentUpon>
+                  <LogicalName>
+                  </LogicalName>
                 </EmbeddedResource>
               </ItemGroup>
               <ItemGroup>
                 <ProjectReference Include="..\Implab.Fx\Implab.Fx.csproj">
                   <Project>{06E706F8-6881-43EB-927E-FFC503AF6ABC}</Project>
                   <Name>Implab.Fx</Name>
                 </ProjectReference>
                 <ProjectReference Include="..\Implab\Implab.csproj">
                   <Project>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</Project>
                   <Name>Implab</Name>
                 </ProjectReference>
               </ItemGroup>
               <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
               <!-- To modify your build process, add your task inside one of the targets below and uncomment it.
                    Other similar extension points exist, see Microsoft.Common.targets.
               <Target Name="BeforeBuild">
               </Target>
               <Target Name="AfterBuild">
               </Target>
               -->
             </Project>

Implab.Fx/Implab.Fx.csproj +2 -1

             <?xml version="1.0" encoding="utf-8"?>
             <Project ToolsVersion="4.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
               <PropertyGroup>
                 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
                 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
                 <ProductVersion>8.0.30703</ProductVersion>
                 <SchemaVersion>2.0</SchemaVersion>
                 <ProjectGuid>{06E706F8-6881-43EB-927E-FFC503AF6ABC}</ProjectGuid>
                 <OutputType>Library</OutputType>
                 <AppDesignerFolder>Properties</AppDesignerFolder>
                 <RootNamespace>Implab.Fx</RootNamespace>
                 <AssemblyName>Implab.Fx</AssemblyName>
                 <TargetFrameworkVersion>v4.0</TargetFrameworkVersion>
                 <FileAlignment>512</FileAlignment>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug\</OutputPath>
                 <DefineConstants>DEBUG;TRACE</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
                 <DebugType>pdbonly</DebugType>
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release\</OutputPath>
                 <DefineConstants>TRACE</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
               </PropertyGroup>
               <ItemGroup>
                 <Reference Include="System" />
                 <Reference Include="System.Core" />
                 <Reference Include="System.Drawing" />
                 <Reference Include="System.Windows.Forms" />
                 <Reference Include="System.Xml.Linq" />
                 <Reference Include="System.Data.DataSetExtensions" />
                 <Reference Include="Microsoft.CSharp" />
                 <Reference Include="System.Data" />
                 <Reference Include="System.Xml" />
               </ItemGroup>
               <ItemGroup>
                 <Compile Include="Animation.cs" />
                 <Compile Include="AnimationHelpers.cs" />
                 <Compile Include="PromiseHelpers.cs" />
                 <Compile Include="Properties\AssemblyInfo.cs" />
+                <Compile Include="ControlBoundPromise.cs" />
               </ItemGroup>
               <ItemGroup>
                 <ProjectReference Include="..\Implab\Implab.csproj">
-                  <Project>{99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}</Project>
+                  <Project>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</Project>
                   <Name>Implab</Name>
                 </ProjectReference>
               </ItemGroup>
               <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
               <!-- To modify your build process, add your task inside one of the targets below and uncomment it.
                    Other similar extension points exist, see Microsoft.Common.targets.
               <Target Name="BeforeBuild">
               </Target>
               <Target Name="AfterBuild">
               </Target>
               -->
             </Project>

Implab.Fx/PromiseHelpers.cs +7 -15

             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>
                     public static Promise<T> DispatchToControl<T>(this Promise<T> that, Control ctl)
                     {
                         if (that == null)
                             throw new ArgumentNullException("that");
                         if (ctl == null)
                             throw new ArgumentNullException("ctl");
-                        var directed = new Promise<T>();
+                        var directed = new ControlBoundPromise<T>(ctl,that,true);
                         that.Then(
-                            res =>
+                            directed.Resolve,
-                                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 default(T);
                             }
                         );
                         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)
+                            err => {
+                                sync.Post(state => d.Reject(err), null);
+                                return default(T);
+                            }
                         );
                         return d;
                     }
                 }
             }

Implab.Test/Implab.Test.csproj +1 -7

             <?xml version="1.0" encoding="utf-8"?>
             <Project ToolsVersion="4.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
               <PropertyGroup>
                 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
                 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-                <ProductVersion>
+                <ProductVersion>8.0.30703</ProductVersion>
-                </ProductVersion>
                 <SchemaVersion>2.0</SchemaVersion>
                 <ProjectGuid>{63F92C0C-61BF-48C0-A377-8D67C3C661D0}</ProjectGuid>
                 <OutputType>Library</OutputType>
                 <AppDesignerFolder>Properties</AppDesignerFolder>
                 <RootNamespace>Implab.Test</RootNamespace>
                 <AssemblyName>Implab.Test</AssemblyName>
                 <TargetFrameworkVersion>v4.0</TargetFrameworkVersion>
                 <FileAlignment>512</FileAlignment>
                 <ProjectTypeGuids>{3AC096D0-A1C2-E12C-1390-A8335801FDAB};{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}</ProjectTypeGuids>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug\</OutputPath>
                 <DefineConstants>DEBUG;TRACE</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
                 <DebugType>pdbonly</DebugType>
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release\</OutputPath>
                 <DefineConstants>TRACE</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
               </PropertyGroup>
               <ItemGroup>
                 <Reference Include="Microsoft.VisualStudio.QualityTools.UnitTestFramework, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL" />
                 <Reference Include="System" />
                 <Reference Include="System.Core">
                   <RequiredTargetFramework>3.5</RequiredTargetFramework>
                 </Reference>
               </ItemGroup>
               <ItemGroup>
-                <CodeAnalysisDependentAssemblyPaths Condition=" '$(VS100COMNTOOLS)' != '' " Include="$(VS100COMNTOOLS)..\IDE\PrivateAssemblies">
-                  <Visible>False</Visible>
-                </CodeAnalysisDependentAssemblyPaths>
-              </ItemGroup>
-              <ItemGroup>
                 <Compile Include="AsyncTests.cs" />
                 <Compile Include="PromiseHelper.cs" />
                 <Compile Include="Properties\AssemblyInfo.cs" />
               </ItemGroup>
               <ItemGroup>
                 <ProjectReference Include="..\Implab\Implab.csproj">
                   <Project>{99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}</Project>
                   <Name>Implab</Name>
                 </ProjectReference>
               </ItemGroup>
               <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
               <!-- To modify your build process, add your task inside one of the targets below and uncomment it.
                    Other similar extension points exist, see Microsoft.Common.targets.
               <Target Name="BeforeBuild">
               </Target>
               <Target Name="AfterBuild">
               </Target>
               -->
             </Project>

Implab.sln +215 -14

@@ -1,51 +1,252
1		1
2	Microsoft Visual Studio Solution File, Format Version 11.00	2	Microsoft Visual Studio Solution File, Format Version 11.00
3	# Visual Studio 2010	3	# Visual Studio 2010
4	Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab", "Implab\Implab.csproj", "{F550F1F8-8746-4AD0-9614-855F4C4B7F05}"	4	Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab", "Implab\Implab.csproj", "{F550F1F8-8746-4AD0-9614-855F4C4B7F05}"
5	EndProject	5	EndProject
6	Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{CE8D8D18-437A-445C-B662-4C2CE79A76F6}"	6	Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{CE8D8D18-437A-445C-B662-4C2CE79A76F6}"
7	ProjectSection(SolutionItems) = preProject	7	ProjectSection(SolutionItems) = preProject
8	Implab.vsmdi = Implab.vsmdi	8	Implab.vsmdi = Implab.vsmdi
9	Local.testsettings = Local.testsettings	9	Local.testsettings = Local.testsettings
10	TraceAndTestImpact.testsettings = TraceAndTestImpact.testsettings	10	TraceAndTestImpact.testsettings = TraceAndTestImpact.testsettings
11	EndProjectSection	11	EndProjectSection
12	EndProject	12	EndProject
13	Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Test", "Implab.Test\Implab.Test.csproj", "{63F92C0C-61BF-48C0-A377-8D67C3C661D0}"	13	Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Test", "Implab.Test\Implab.Test.csproj", "{63F92C0C-61BF-48C0-A377-8D67C3C661D0}"
14	EndProject	14	EndProject
15	Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Fx", "Implab.Fx\Implab.Fx.csproj", "{06E706F8-6881-43EB-927E-FFC503AF6ABC}"	15	Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Fx", "Implab.Fx\Implab.Fx.csproj", "{06E706F8-6881-43EB-927E-FFC503AF6ABC}"
16	EndProject	16	EndProject
17	Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Fx.Test", "Implab.Fx.Test\Implab.Fx.Test.csproj", "{2F31E405-E267-4195-A05D-574093C21209}"	17	Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Fx.Test", "Implab.Fx.Test\Implab.Fx.Test.csproj", "{2F31E405-E267-4195-A05D-574093C21209}"
18	EndProject	18	EndProject
19	Global	19	Global
20	GlobalSection(TestCaseManagementSettings) = postSolution
21	CategoryFile = Implab.vsmdi
22	EndGlobalSection
23	GlobalSection(SolutionConfigurationPlatforms) = preSolution	20	GlobalSection(SolutionConfigurationPlatforms) = preSolution
24	Debug\|Any CPU = Debug\|Any CPU	21	Debug\|Any CPU = Debug\|Any CPU
25	Release\|Any CPU = Release\|Any CPU	22	Release\|Any CPU = Release\|Any CPU
26	EndGlobalSection	23	EndGlobalSection
27	GlobalSection(ProjectConfigurationPlatforms) = postSolution	24	GlobalSection(ProjectConfigurationPlatforms) = postSolution
28	{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Debug\|Any CPU.ActiveCfg = Debug\|Any CPU
29	{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Debug\|Any CPU.Build.0 = Debug\|Any CPU
30	{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Release\|Any CPU.ActiveCfg = Release\|Any CPU
31	{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Release\|Any CPU.Build.0 = Release\|Any CPU
32	{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug\|Any CPU.ActiveCfg = Debug\|Any CPU
33	{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug\|Any CPU.Build.0 = Debug\|Any CPU
34	{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release\|Any CPU.ActiveCfg = Release\|Any CPU
35	{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release\|Any CPU.Build.0 = Release\|Any CPU
36	{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Debug\|Any CPU.ActiveCfg = Debug\|Any CPU	25	{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Debug\|Any CPU.ActiveCfg = Debug\|Any CPU
37	{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Debug\|Any CPU.Build.0 = Debug\|Any CPU	26	{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Debug\|Any CPU.Build.0 = Debug\|Any CPU
38	{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Release\|Any CPU.ActiveCfg = Release\|Any CPU	27	{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Release\|Any CPU.ActiveCfg = Release\|Any CPU
39	{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Release\|Any CPU.Build.0 = Release\|Any CPU	28	{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Release\|Any CPU.Build.0 = Release\|Any CPU
40	{2F31E405-E267-4195-A05D-574093C21209}.Debug\|Any CPU.ActiveCfg = Debug\|Any CPU	29	{2F31E405-E267-4195-A05D-574093C21209}.Debug\|Any CPU.ActiveCfg = Debug\|Any CPU
41	{2F31E405-E267-4195-A05D-574093C21209}.Debug\|Any CPU.Build.0 = Debug\|Any CPU	30	{2F31E405-E267-4195-A05D-574093C21209}.Debug\|Any CPU.Build.0 = Debug\|Any CPU
42	{2F31E405-E267-4195-A05D-574093C21209}.Release\|Any CPU.ActiveCfg = Release\|Any CPU	31	{2F31E405-E267-4195-A05D-574093C21209}.Release\|Any CPU.ActiveCfg = Release\|Any CPU
43	{2F31E405-E267-4195-A05D-574093C21209}.Release\|Any CPU.Build.0 = Release\|Any CPU	32	{2F31E405-E267-4195-A05D-574093C21209}.Release\|Any CPU.Build.0 = Release\|Any CPU
		33	{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug\|Any CPU.ActiveCfg = Debug\|Any CPU
		34	{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug\|Any CPU.Build.0 = Debug\|Any CPU
		35	{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release\|Any CPU.ActiveCfg = Release\|Any CPU
		36	{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release\|Any CPU.Build.0 = Release\|Any CPU
		37	{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Debug\|Any CPU.ActiveCfg = Debug\|Any CPU
		38	{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Debug\|Any CPU.Build.0 = Debug\|Any CPU
		39	{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Release\|Any CPU.ActiveCfg = Release\|Any CPU
		40	{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Release\|Any CPU.Build.0 = Release\|Any CPU
		41	EndGlobalSection
		42	GlobalSection(NestedProjects) = preSolution
		43	EndGlobalSection
		44	GlobalSection(MonoDevelopProperties) = preSolution
		45	StartupItem = Implab\Implab.csproj
		46	Policies = $0
		47	$0.CSharpFormattingPolicy = $1
		48	$1.IndentSwitchBody = True
		49	$1.NamespaceBraceStyle = EndOfLine
		50	$1.ClassBraceStyle = EndOfLine
		51	$1.InterfaceBraceStyle = EndOfLine
		52	$1.StructBraceStyle = EndOfLine
		53	$1.EnumBraceStyle = EndOfLine
		54	$1.MethodBraceStyle = EndOfLine
		55	$1.ConstructorBraceStyle = EndOfLine
		56	$1.DestructorBraceStyle = EndOfLine
		57	$1.BeforeMethodDeclarationParentheses = False
		58	$1.BeforeMethodCallParentheses = False
		59	$1.BeforeConstructorDeclarationParentheses = False
		60	$1.NewLineBeforeConstructorInitializerColon = NewLine
		61	$1.NewLineAfterConstructorInitializerColon = SameLine
		62	$1.BeforeIndexerDeclarationBracket = False
		63	$1.BeforeDelegateDeclarationParentheses = False
		64	$1.NewParentheses = False
		65	$1.SpacesBeforeBrackets = False
		66	$1.inheritsSet = Mono
		67	$1.inheritsScope = text/x-csharp
		68	$1.scope = text/x-csharp
		69	$0.TextStylePolicy = $2
		70	$2.FileWidth = 120
		71	$2.EolMarker = Unix
		72	$2.inheritsSet = VisualStudio
		73	$2.inheritsScope = text/plain
		74	$2.scope = text/x-csharp
		75	$0.DotNetNamingPolicy = $3
		76	$3.DirectoryNamespaceAssociation = PrefixedHierarchical
		77	$3.ResourceNamePolicy = MSBuild
		78	$0.TextStylePolicy = $4
		79	$4.FileWidth = 120
		80	$4.TabsToSpaces = False
		81	$4.inheritsSet = VisualStudio
		82	$4.inheritsScope = text/plain
		83	$4.scope = application/xml
		84	$0.XmlFormattingPolicy = $5
		85	$5.inheritsSet = Mono
		86	$5.inheritsScope = application/xml
		87	$5.scope = application/xml
		88	$0.TextStylePolicy = $6
		89	$6.FileWidth = 120
		90	$6.TabsToSpaces = False
		91	$6.inheritsSet = VisualStudio
		92	$6.inheritsScope = text/plain
		93	$6.scope = text/plain
		94	$0.NameConventionPolicy = $7
		95	$7.Rules = $8
		96	$8.NamingRule = $9
		97	$9.Name = Namespaces
		98	$9.AffectedEntity = Namespace
		99	$9.VisibilityMask = VisibilityMask
		100	$9.NamingStyle = PascalCase
		101	$9.IncludeInstanceMembers = True
		102	$9.IncludeStaticEntities = True
		103	$8.NamingRule = $10
		104	$10.Name = Types
		105	$10.AffectedEntity = Class, Struct, Enum, Delegate
		106	$10.VisibilityMask = VisibilityMask
		107	$10.NamingStyle = PascalCase
		108	$10.IncludeInstanceMembers = True
		109	$10.IncludeStaticEntities = True
		110	$8.NamingRule = $11
		111	$11.Name = Interfaces
		112	$11.RequiredPrefixes = $12
		113	$12.String = I
		114	$11.AffectedEntity = Interface
		115	$11.VisibilityMask = VisibilityMask
		116	$11.NamingStyle = PascalCase
		117	$11.IncludeInstanceMembers = True
		118	$11.IncludeStaticEntities = True
		119	$8.NamingRule = $13
		120	$13.Name = Attributes
		121	$13.RequiredSuffixes = $14
		122	$14.String = Attribute
		123	$13.AffectedEntity = CustomAttributes
		124	$13.VisibilityMask = VisibilityMask
		125	$13.NamingStyle = PascalCase
		126	$13.IncludeInstanceMembers = True
		127	$13.IncludeStaticEntities = True
		128	$8.NamingRule = $15
		129	$15.Name = Event Arguments
		130	$15.RequiredSuffixes = $16
		131	$16.String = EventArgs
		132	$15.AffectedEntity = CustomEventArgs
		133	$15.VisibilityMask = VisibilityMask
		134	$15.NamingStyle = PascalCase
		135	$15.IncludeInstanceMembers = True
		136	$15.IncludeStaticEntities = True
		137	$8.NamingRule = $17
		138	$17.Name = Exceptions
		139	$17.RequiredSuffixes = $18
		140	$18.String = Exception
		141	$17.AffectedEntity = CustomExceptions
		142	$17.VisibilityMask = VisibilityMask
		143	$17.NamingStyle = PascalCase
		144	$17.IncludeInstanceMembers = True
		145	$17.IncludeStaticEntities = True
		146	$8.NamingRule = $19
		147	$19.Name = Methods
		148	$19.AffectedEntity = Methods
		149	$19.VisibilityMask = VisibilityMask
		150	$19.NamingStyle = PascalCase
		151	$19.IncludeInstanceMembers = True
		152	$19.IncludeStaticEntities = True
		153	$8.NamingRule = $20
		154	$20.Name = Static Readonly Fields
		155	$20.AffectedEntity = ReadonlyField
		156	$20.VisibilityMask = Internal, Protected, Public
		157	$20.NamingStyle = CamelCase
		158	$20.IncludeInstanceMembers = False
		159	$20.IncludeStaticEntities = True
		160	$8.NamingRule = $21
		161	$21.Name = Fields (Non Private)
		162	$21.AffectedEntity = Field
		163	$21.VisibilityMask = Internal, Public
		164	$21.NamingStyle = CamelCase
		165	$21.IncludeInstanceMembers = True
		166	$21.IncludeStaticEntities = True
		167	$8.NamingRule = $22
		168	$22.Name = ReadOnly Fields (Non Private)
		169	$22.AffectedEntity = ReadonlyField
		170	$22.VisibilityMask = Internal, Public
		171	$22.NamingStyle = CamelCase
		172	$22.IncludeInstanceMembers = True
		173	$22.IncludeStaticEntities = False
		174	$8.NamingRule = $23
		175	$23.Name = Fields (Private)
		176	$23.RequiredPrefixes = $24
		177	$24.String = m_
		178	$23.AffectedEntity = Field, ReadonlyField
		179	$23.VisibilityMask = Private, Protected
		180	$23.NamingStyle = CamelCase
		181	$23.IncludeInstanceMembers = True
		182	$23.IncludeStaticEntities = False
		183	$8.NamingRule = $25
		184	$25.Name = Static Fields (Private)
		185	$25.RequiredPrefixes = $26
		186	$26.String = _
		187	$25.AffectedEntity = Field
		188	$25.VisibilityMask = Private
		189	$25.NamingStyle = CamelCase
		190	$25.IncludeInstanceMembers = False
		191	$25.IncludeStaticEntities = True
		192	$8.NamingRule = $27
		193	$27.Name = ReadOnly Fields (Private)
		194	$27.RequiredPrefixes = $28
		195	$28.String = m_
		196	$27.AffectedEntity = ReadonlyField
		197	$27.VisibilityMask = Private, Protected
		198	$27.NamingStyle = CamelCase
		199	$27.IncludeInstanceMembers = True
		200	$27.IncludeStaticEntities = False
		201	$8.NamingRule = $29
		202	$29.Name = Constant Fields
		203	$29.AffectedEntity = ConstantField
		204	$29.VisibilityMask = VisibilityMask
		205	$29.NamingStyle = AllUpper
		206	$29.IncludeInstanceMembers = True
		207	$29.IncludeStaticEntities = True
		208	$8.NamingRule = $30
		209	$30.Name = Properties
		210	$30.AffectedEntity = Property
		211	$30.VisibilityMask = VisibilityMask
		212	$30.NamingStyle = PascalCase
		213	$30.IncludeInstanceMembers = True
		214	$30.IncludeStaticEntities = True
		215	$8.NamingRule = $31
		216	$31.Name = Events
		217	$31.AffectedEntity = Event
		218	$31.VisibilityMask = VisibilityMask
		219	$31.NamingStyle = PascalCase
		220	$31.IncludeInstanceMembers = True
		221	$31.IncludeStaticEntities = True
		222	$8.NamingRule = $32
		223	$32.Name = Enum Members
		224	$32.AffectedEntity = EnumMember
		225	$32.VisibilityMask = VisibilityMask
		226	$32.NamingStyle = PascalCase
		227	$32.IncludeInstanceMembers = True
		228	$32.IncludeStaticEntities = True
		229	$8.NamingRule = $33
		230	$33.Name = Parameters
		231	$33.AffectedEntity = Parameter, LocalVariable
		232	$33.VisibilityMask = VisibilityMask
		233	$33.NamingStyle = CamelCase
		234	$33.IncludeInstanceMembers = True
		235	$33.IncludeStaticEntities = True
		236	$8.NamingRule = $34
		237	$34.Name = Type Parameters
		238	$34.RequiredPrefixes = $35
		239	$35.String = T
		240	$34.AffectedEntity = TypeParameter
		241	$34.VisibilityMask = VisibilityMask
		242	$34.NamingStyle = PascalCase
		243	$34.IncludeInstanceMembers = True
		244	$34.IncludeStaticEntities = True
		245	EndGlobalSection
		246	GlobalSection(TestCaseManagementSettings) = postSolution
		247	CategoryFile = Implab.vsmdi
44	EndGlobalSection	248	EndGlobalSection
45	GlobalSection(SolutionProperties) = preSolution	249	GlobalSection(SolutionProperties) = preSolution
46	HideSolutionNode = FALSE	250	HideSolutionNode = FALSE
47	EndGlobalSection	251	EndGlobalSection
48	GlobalSection(MonoDevelopProperties) = preSolution
49	StartupItem = Implab\Implab.csproj
50	EndGlobalSection
51	EndGlobal	252	EndGlobal

Implab/IPromiseT.cs +2 -4

             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             namespace Implab
             {
                 public interface IPromise<T>: IPromise
                 {
                     new T Join();
                     new T Join(int timeout);
-                    IPromise<T> Then(ResultHandler<T> success, ErrorHandler error);
                     IPromise<T> Then(ResultHandler<T> success, ErrorHandler<T> error);
                     IPromise<T> Then(ResultHandler<T> success);
-                    new IPromise<T> Error(ErrorHandler error);
                     IPromise<T> Error(ErrorHandler<T> error);
-                    IPromise<T2> Map<T2>(ResultMapper<T,T2> mapper, ErrorHandler error);
+                    IPromise<T2> Map<T2>(ResultMapper<T,T2> mapper, ErrorHandler<T> error);
                     IPromise<T2> Map<T2>(ResultMapper<T, T2> mapper);
-                    IPromise<T2> Chain<T2>(ChainedOperation<T, T2> chained, ErrorHandler error);
+                    IPromise<T2> Chain<T2>(ChainedOperation<T, T2> chained, ErrorHandler<T> error);
                     IPromise<T2> Chain<T2>(ChainedOperation<T, T2> chained);
                     new IPromise<T> Cancelled(Action handler);
                     new IPromise<T> Finally(Action handler);
                     new IPromise<T> Anyway(Action handler);
                 }
             }

Implab/Implab.csproj +74 0

             <?xml version="1.0" encoding="utf-8"?>
             <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
               <PropertyGroup>
                 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
                 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
                 <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid>
                 <OutputType>Library</OutputType>
                 <RootNamespace>Implab</RootNamespace>
                 <AssemblyName>Implab</AssemblyName>
+                <ProductVersion>8.0.30703</ProductVersion>
+                <SchemaVersion>2.0</SchemaVersion>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug</OutputPath>
                 <DefineConstants>TRACE;DEBUG;</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
                 <RunCodeAnalysis>true</RunCodeAnalysis>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
                 <DebugType>full</DebugType>
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release</OutputPath>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <ItemGroup>
                 <Reference Include="System" />
                 <Reference Include="System.Xml" />
               </ItemGroup>
               <ItemGroup>
                 <Compile Include="Component.cs" />
                 <Compile Include="CustomEqualityComparer.cs" />
                 <Compile Include="Diagnostics\ConsoleTraceListener.cs" />
                 <Compile Include="Diagnostics\EventText.cs" />
                 <Compile Include="Diagnostics\IEventTextFormatter.cs" />
                 <Compile Include="Diagnostics\LogChannel.cs" />
                 <Compile Include="Diagnostics\LogicalOperation.cs" />
                 <Compile Include="Diagnostics\TextFileListener.cs" />
                 <Compile Include="Diagnostics\TextListenerBase.cs" />
                 <Compile Include="Diagnostics\TraceLog.cs" />
                 <Compile Include="Diagnostics\TraceContext.cs" />
                 <Compile Include="Diagnostics\TraceEvent.cs" />
                 <Compile Include="Diagnostics\TraceEventType.cs" />
                 <Compile Include="Disposable.cs" />
                 <Compile Include="ICancellable.cs" />
                 <Compile Include="IProgressHandler.cs" />
                 <Compile Include="IProgressNotifier.cs" />
                 <Compile Include="IPromiseT.cs" />
                 <Compile Include="IPromise.cs" />
                 <Compile Include="IServiceLocator.cs" />
                 <Compile Include="ITaskController.cs" />
                 <Compile Include="JSON\JSONElementContext.cs" />
                 <Compile Include="JSON\JSONElementType.cs" />
                 <Compile Include="JSON\JSONGrammar.cs" />
                 <Compile Include="JSON\JSONParser.cs" />
                 <Compile Include="JSON\JSONScanner.cs" />
                 <Compile Include="JSON\JsonTokenType.cs" />
                 <Compile Include="JSON\JSONWriter.cs" />
                 <Compile Include="JSON\JSONXmlReader.cs" />
                 <Compile Include="JSON\JSONXmlReaderOptions.cs" />
                 <Compile Include="JSON\StringTranslator.cs" />
                 <Compile Include="Parallels\DispatchPool.cs" />
                 <Compile Include="Parallels\ArrayTraits.cs" />
                 <Compile Include="Parallels\MTQueue.cs" />
                 <Compile Include="Parallels\WorkerPool.cs" />
                 <Compile Include="Parsing\Alphabet.cs" />
                 <Compile Include="Parsing\AlphabetBase.cs" />
                 <Compile Include="Parsing\AltToken.cs" />
                 <Compile Include="Parsing\BinaryToken.cs" />
                 <Compile Include="Parsing\CatToken.cs" />
                 <Compile Include="Parsing\CDFADefinition.cs" />
                 <Compile Include="Parsing\DFABuilder.cs" />
                 <Compile Include="Parsing\DFADefinitionBase.cs" />
                 <Compile Include="Parsing\DFAStateDescriptor.cs" />
                 <Compile Include="Parsing\DFAutomaton.cs" />
                 <Compile Include="Parsing\EDFADefinition.cs" />
                 <Compile Include="Parsing\EmptyToken.cs" />
                 <Compile Include="Parsing\EndToken.cs" />
                 <Compile Include="Parsing\EnumAlphabet.cs" />
                 <Compile Include="Parsing\Grammar.cs" />
                 <Compile Include="Parsing\IAlphabet.cs" />
                 <Compile Include="Parsing\IDFADefinition.cs" />
                 <Compile Include="Parsing\IVisitor.cs" />
                 <Compile Include="Parsing\ParserException.cs" />
                 <Compile Include="Parsing\Scanner.cs" />
                 <Compile Include="Parsing\StarToken.cs" />
                 <Compile Include="Parsing\SymbolToken.cs" />
                 <Compile Include="Parsing\Token.cs" />
                 <Compile Include="SafePool.cs" />
                 <Compile Include="ServiceLocator.cs" />
                 <Compile Include="TaskController.cs" />
                 <Compile Include="ProgressInitEventArgs.cs" />
                 <Compile Include="Properties\AssemblyInfo.cs" />
                 <Compile Include="Promise.cs" />
                 <Compile Include="Parallels\AsyncPool.cs" />
                 <Compile Include="Safe.cs" />
                 <Compile Include="ValueEventArgs.cs" />
+                <Compile Include="PromiseExtensions.cs" />
+                <Compile Include="TransientPromiseException.cs" />
+                <Compile Include="SyncContextPromise.cs" />
               </ItemGroup>
               <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
               <ItemGroup />
+              <ProjectExtensions>
+                <MonoDevelop>
+                  <Properties>
+                    <Policies>
+                      <CSharpFormattingPolicy IndentSwitchBody="True" NamespaceBraceStyle="EndOfLine" ClassBraceStyle="EndOfLine" InterfaceBraceStyle="EndOfLine" StructBraceStyle="EndOfLine" EnumBraceStyle="EndOfLine" MethodBraceStyle="EndOfLine" ConstructorBraceStyle="EndOfLine" DestructorBraceStyle="EndOfLine" BeforeMethodDeclarationParentheses="False" BeforeMethodCallParentheses="False" BeforeConstructorDeclarationParentheses="False" NewLineBeforeConstructorInitializerColon="NewLine" NewLineAfterConstructorInitializerColon="SameLine" BeforeIndexerDeclarationBracket="False" BeforeDelegateDeclarationParentheses="False" NewParentheses="False" SpacesBeforeBrackets="False" inheritsSet="Mono" inheritsScope="text/x-csharp" scope="text/x-csharp" />
+                      <TextStylePolicy FileWidth="120" EolMarker="Unix" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/x-csharp" />
+                      <DotNetNamingPolicy DirectoryNamespaceAssociation="PrefixedHierarchical" ResourceNamePolicy="MSBuild" />
+                      <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="application/xml" />
+                      <XmlFormattingPolicy inheritsSet="Mono" inheritsScope="application/xml" scope="application/xml" />
+                      <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/plain" />
+                      <NameConventionPolicy>
+                        <Rules>
+                          <NamingRule Name="Namespaces" AffectedEntity="Namespace" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="Types" AffectedEntity="Class, Struct, Enum, Delegate" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="Interfaces" AffectedEntity="Interface" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
+                            <RequiredPrefixes>
+                              <String>I</String>
+                            </RequiredPrefixes>
+                          </NamingRule>
+                          <NamingRule Name="Attributes" AffectedEntity="CustomAttributes" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
+                            <RequiredSuffixes>
+                              <String>Attribute</String>
+                            </RequiredSuffixes>
+                          </NamingRule>
+                          <NamingRule Name="Event Arguments" AffectedEntity="CustomEventArgs" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
+                            <RequiredSuffixes>
+                              <String>EventArgs</String>
+                            </RequiredSuffixes>
+                          </NamingRule>
+                          <NamingRule Name="Exceptions" AffectedEntity="CustomExceptions" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
+                            <RequiredSuffixes>
+                              <String>Exception</String>
+                            </RequiredSuffixes>
+                          </NamingRule>
+                          <NamingRule Name="Methods" AffectedEntity="Methods" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="Static Readonly Fields" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Protected, Public" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True" />
+                          <NamingRule Name="Fields (Non Private)" AffectedEntity="Field" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="ReadOnly Fields (Non Private)" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False" />
+                          <NamingRule Name="Fields (Private)" AffectedEntity="Field, ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False">
+                            <RequiredPrefixes>
+                              <String>m_</String>
+                            </RequiredPrefixes>
+                          </NamingRule>
+                          <NamingRule Name="Static Fields (Private)" AffectedEntity="Field" VisibilityMask="Private" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True">
+                            <RequiredPrefixes>
+                              <String>_</String>
+                            </RequiredPrefixes>
+                          </NamingRule>
+                          <NamingRule Name="ReadOnly Fields (Private)" AffectedEntity="ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False">
+                            <RequiredPrefixes>
+                              <String>m_</String>
+                            </RequiredPrefixes>
+                          </NamingRule>
+                          <NamingRule Name="Constant Fields" AffectedEntity="ConstantField" VisibilityMask="VisibilityMask" NamingStyle="AllUpper" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="Properties" AffectedEntity="Property" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="Events" AffectedEntity="Event" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="Enum Members" AffectedEntity="EnumMember" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="Parameters" AffectedEntity="Parameter, LocalVariable" VisibilityMask="VisibilityMask" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
+                          <NamingRule Name="Type Parameters" AffectedEntity="TypeParameter" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
+                            <RequiredPrefixes>
+                              <String>T</String>
+                            </RequiredPrefixes>
+                          </NamingRule>
+                        </Rules>
+                      </NameConventionPolicy>
+                    </Policies>
+                  </Properties>
+                </MonoDevelop>
+              </ProjectExtensions>
             </Project>

Implab/JSON/JSONGrammar.cs 0 -10

             using Implab.Parsing;
             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             using System.Threading.Tasks;
             namespace Implab.JSON {
                 internal class JSONGrammar : Grammar<JSONGrammar> {
                     public enum TokenType : int {
                         None,
                         BeginObject,
                         EndObject,
                         BeginArray,
                         EndArray,
                         String,
                         Number,
                         Literal,
                         NameSeparator,
                         ValueSeparator,
                         StringBound,
                         EscapedChar,
                         UnescapedChar,
                         EscapedUnicode,
                         Minus,
                         Plus,
                         Sign,
                         Integer,
                         Dot,
                         Exp
                     }
                     readonly CDFADefinition m_jsonDFA;
                     readonly CDFADefinition m_stringDFA;
                     public JSONGrammar() {
                         DefineAlphabet(Enumerable.Range(0, 0x20).Select(x => (char)x));
                         var hexDigit = SymbolRangeToken('a','f').Or(SymbolRangeToken('A','F')).Or(SymbolRangeToken('0','9'));
                         var digit9 = SymbolRangeToken('1', '9');
                         var zero = SymbolToken('0');
                         var digit = zero.Or(digit9);
                         var dot = SymbolToken('.');
                         var minus = SymbolToken('-');
                         var sign = SymbolSetToken('-', '+');
                         var expSign = SymbolSetToken('e', 'E');
                         var letters = SymbolRangeToken('a', 'z');
                         var integer = zero.Or(digit9.Cat(digit.EClosure()));
                         var frac = dot.Cat(digit.Closure());
                         var exp = expSign.Cat(sign.Optional()).Cat(digit.Closure());
                         var quote = SymbolToken('"');
                         var backSlash = SymbolToken('\\');
                         var specialEscapeChars = SymbolSetToken('\\', '"', '/', 'b', 'f', 't', 'n', 'r');
                         var unicodeEspace = SymbolToken('u').Cat(hexDigit.Repeat(4));
-                        var escape = backSlash.Cat(specialEscapeChars.Or(unicodeEspace));
                         var whitespace = SymbolSetToken('\n', '\r', '\t', ' ').EClosure();
                         var beginObject = whitespace.Cat(SymbolToken('{')).Cat(whitespace);
                         var endObject = whitespace.Cat(SymbolToken('}')).Cat(whitespace);
                         var beginArray = whitespace.Cat(SymbolToken('[')).Cat(whitespace);
                         var endArray = whitespace.Cat(SymbolToken(']')).Cat(whitespace);
                         var nameSep = whitespace.Cat(SymbolToken(':')).Cat(whitespace);
                         var valueSep = whitespace.Cat(SymbolToken(',')).Cat(whitespace);
                         var number = minus.Optional().Cat(integer).Cat(frac.Optional()).Cat(exp.Optional());
                         var literal = letters.Closure();
                         var unescaped = SymbolTokenExcept(Enumerable.Range(0, 0x20).Union(new int[] { '\\', '"' }).Select(x => (char)x));
-                        var character = unescaped.Or(escape);
-                        var str = quote.Cat(character.EClosure()).Cat(quote);
                         var jsonExpression =
                             number.Tag(TokenType.Number)
                             .Or(literal.Tag(TokenType.Literal))
                             .Or(quote.Tag(TokenType.StringBound))
                             .Or(beginObject.Tag(TokenType.BeginObject))
                             .Or(endObject.Tag(TokenType.EndObject))
                             .Or(beginArray.Tag(TokenType.BeginArray))
                             .Or(endArray.Tag(TokenType.EndArray))
                             .Or(nameSep.Tag(TokenType.NameSeparator))
                             .Or(valueSep.Tag(TokenType.ValueSeparator));
                         var jsonStringExpression =
                             quote.Tag(TokenType.StringBound)
                             .Or(backSlash.Cat(specialEscapeChars).Tag(TokenType.EscapedChar))
                             .Or(backSlash.Cat(unicodeEspace).Tag(TokenType.EscapedUnicode))
                             .Or(unescaped.Closure().Tag(TokenType.UnescapedChar));
-                        var jsonNumberExpression =
-                            minus.Tag(TokenType.Minus)
-                            .Or(SymbolToken('+').Tag(TokenType.Plus))
-                            .Or(digit.Closure().Tag(TokenType.Integer))
-                            .Or(dot.Tag(TokenType.Dot))
-                            .Or(expSign.Tag(TokenType.Exp));
                         m_jsonDFA = BuildDFA(jsonExpression);
                         m_stringDFA = BuildDFA(jsonStringExpression);
                     }
                     public CDFADefinition JsonDFA {
                         get {
                             return m_jsonDFA;
                         }
                     }
                     public CDFADefinition JsonStringDFA {
                         get {
                             return m_stringDFA;
                         }
                     }
                 }
             }

Implab/JSON/JSONWriter.cs +37 -8

             using System;
             using System.Collections.Generic;
             using System.IO;
             using System.Linq;
             using System.Text;
             using System.Threading.Tasks;
             namespace Implab.JSON {
                 public class JSONWriter {
                     struct Context {
                         public bool needComma;
                         public JSONElementContext element;
                     }
                     Stack<Context> m_contextStack = new Stack<Context>();
                     Context m_context;
                     TextWriter m_writer;
-                    bool m_indent;
+                    readonly bool m_indent = true;
+                    readonly int m_indentSize = 4;
                     static readonly char [] _escapeBKS,
                         _escapeFWD,
                         _escapeCR,
                         _escapeNL,
                         _escapeTAB,
                         _escapeSLASH,
                         _escapeBSLASH,
                         _escapeQ;
                     static JSONWriter() {
                         _escapeBKS = "\\b".ToCharArray();
                         _escapeFWD = "\\f".ToCharArray();
                         _escapeCR = "\\r".ToCharArray();
                         _escapeNL = "\\n".ToCharArray();
                         _escapeTAB = "\\t".ToCharArray();
                         _escapeBSLASH = "\\\\".ToCharArray();
                         _escapeSLASH = "\\/".ToCharArray();
                         _escapeQ = "\\\"".ToCharArray();
                     }
                     public JSONWriter(TextWriter writer) {
                         Safe.ArgumentNotNull(writer, "writer");
                         m_writer = writer;
                     }
+                    public JSONWriter(TextWriter writer, bool indent) {
+                        Safe.ArgumentNotNull(writer, "writer");
+                        m_writer = writer;
+                        m_indent = indent;
+                    }
+                    void WriteIndent() {
+                        if (m_indent) {
+                            var indent = new char[m_contextStack.Count * m_indentSize + 1];
+                            indent[0] = '\n';
+                            for (int i = 1; i < indent.Length; i++)
+                                indent[i] = ' ';
+                            m_writer.Write(new String(indent));
+                        } else {
+                            m_writer.Write(' ');
+                        }
+                    }
                     void WriteMemberName(string name) {
                         Safe.ArgumentNotEmpty(name, "name");
                         if (m_context.element != JSONElementContext.Object)
                             OperationNotApplicable("WriteMember");
                         if (m_context.needComma)
                             m_writer.Write(",");
-                        // TODO indent
+                        WriteIndent();
                         m_context.needComma = true;
                         Write(name);
                         m_writer.Write(" : ");
                     }
                     public void WriteValue(string name, string value) {
                         WriteMemberName(name);
                         Write(value);
                     }
                     public void WriteValue(string name, bool value) {
                         WriteMemberName(name);
                         Write(value);
                     }
                     public void WriteValue(string name, double value) {
                         WriteMemberName(name);
                         Write(value);
                     }
                     public void WriteValue(string value) {
                         if (m_context.element != JSONElementContext.Array)
                             OperationNotApplicable("WriteValue");
                         if (m_context.needComma)
                             m_writer.Write(",");
+                        WriteIndent();
                         m_context.needComma = true;
                         Write(value);
                     }
                     public void WriteValue(bool value) {
                         if (m_context.element != JSONElementContext.Array)
                             OperationNotApplicable("WriteValue");
                         if (m_context.needComma)
                             m_writer.Write(",");
                         m_context.needComma = true;
+                        WriteIndent();
                         Write(value);
                     }
                     public void WriteValue(double value) {
                         if (m_context.element != JSONElementContext.Array)
                             OperationNotApplicable("WriteValue");
                         if (m_context.needComma)
                             m_writer.Write(",");
                         m_context.needComma = true;
+                        WriteIndent();
                         Write(value);
                     }
                     public void BeginObject() {
                         if (m_context.element != JSONElementContext.None && m_context.element != JSONElementContext.Array)
                             OperationNotApplicable("BeginObject");
                         if (m_context.needComma)
                             m_writer.Write(",");
+                        WriteIndent();
                         m_context.needComma = true;
                         m_contextStack.Push(m_context);
                         m_context = new Context { element = JSONElementContext.Object, needComma = false };
                         m_writer.Write("{");
                     }
                     public void BeginObject(string name) {
                         WriteMemberName(name);
                         m_contextStack.Push(m_context);
                         m_context = new Context { element = JSONElementContext.Object, needComma = false };
                         m_writer.Write("{");
                     }
                     public void EndObject() {
                         if (m_context.element != JSONElementContext.Object)
                             OperationNotApplicable("EndArray");
+                        m_context = m_contextStack.Pop();
+                        WriteIndent();
                         m_writer.Write("}");
-                        m_context = m_contextStack.Pop();
                     }
                     public void BeginArray() {
                         if (m_context.element != JSONElementContext.None && m_context.element != JSONElementContext.Array)
                             throw new InvalidOperationException();
-                        if (m_context.needComma)
+                        if (m_context.needComma) {
                             m_writer.Write(",");
+                        }
                         m_context.needComma = true;
+                        WriteIndent();
                         m_contextStack.Push(m_context);
                         m_context = new Context { element = JSONElementContext.Array, needComma = false };
                         m_writer.Write("[");
                     }
                     public void BeginArray(string name) {
                         WriteMemberName(name);
                         m_contextStack.Push(m_context);
                         m_context = new Context { element = JSONElementContext.Array, needComma = false };
                         m_writer.Write("[");
                     }
                     public void EndArray() {
                         if (m_context.element != JSONElementContext.Array)
                             OperationNotApplicable("EndArray");
+                        m_context = m_contextStack.Pop();
+                        WriteIndent();
                         m_writer.Write("]");
-                        m_context = m_contextStack.Pop();
                     }
                     void Write(bool value) {
                         m_writer.Write(value ? "true" : "false");
                     }
                     void Write(string value) {
                         if (value == null)
                             m_writer.Write("null");
                         var chars = value.ToCharArray();
                         m_writer.Write('"');
                         for (int i = 0; i < chars.Length; i++) {
                             var ch = chars[i];
                             switch (ch) {
                                 case '\b':
                                     m_writer.Write(_escapeBKS);
                                     break;
                                 case '\f':
                                     m_writer.Write(_escapeFWD);
                                     break;
                                 case '\r':
                                     m_writer.Write(_escapeCR);
                                     break;
                                 case '\n':
                                     m_writer.Write(_escapeNL);
                                     break;
                                 case '\t':
                                     m_writer.Write(_escapeTAB);
                                     break;
                                 case '\\':
                                     m_writer.Write(_escapeBSLASH);
                                     break;
                                 case '/':
                                     m_writer.Write(_escapeSLASH);
                                     break;
                                 case '"':
                                     m_writer.Write(_escapeQ);
                                     break;
                                 default:
                                     if (ch < 0x20) {
                                         m_writer.Write("\\u00{0:x2}",(int)ch);
                                     } else {
                                         m_writer.Write(ch);
                                     }
                                     break;
                             }
                         }
                         m_writer.Write('"');
                     }
                     void Write(double value) {
                         m_writer.Write(value);
                     }
                     void OperationNotApplicable(string opName) {
                         throw new InvalidOperationException(String.Format("The operation '{0}' isn't applicable in the context of '{1}'", opName, m_context.element ));
                     }
                 }
             }

Implab/Parallels/ArrayTraits.cs +4 -1

             using Implab.Diagnostics;
             using System;
             using System.Collections.Generic;
             using System.Diagnostics;
             using System.Linq;
             using System.Text;
             using System.Threading;
             namespace Implab.Parallels {
                 public static class ArrayTraits {
                     class ArrayIterator<TSrc> : DispatchPool<int> {
                         readonly Action<TSrc> m_action;
                         readonly TSrc[] m_source;
                         readonly Promise<int> m_promise = new Promise<int>();
                         readonly TraceContext m_traceContext;
                         int m_pending;
                         int m_next;
                         public ArrayIterator(TSrc[] source, Action<TSrc> action, int threads)
                             : base(threads) {
                             Debug.Assert(source != null);
                             Debug.Assert(action != null);
                             m_traceContext = TraceContext.Snapshot();
                             m_next = 0;
                             m_source = source;
                             m_pending = source.Length;
                             m_action = action;
                             m_promise.Anyway(() => Dispose());
                             m_promise.Cancelled(() => Dispose());
                             InitPool();
                         }
                         public Promise<int> Promise {
                             get {
                                 return m_promise;
                             }
                         }
                         protected override void Worker() {
                             TraceContext.Fork(m_traceContext);
                             base.Worker();
                         }
                         protected override bool TryDequeue(out int unit) {
                             unit = Interlocked.Increment(ref m_next) - 1;
                             return unit >= m_source.Length ? false : true;
                         }
                         protected override void InvokeUnit(int unit) {
                             try {
                                 m_action(m_source[unit]);
                                 var pending = Interlocked.Decrement(ref m_pending);
                                 if (pending == 0)
                                     m_promise.Resolve(m_source.Length);
                             } catch (Exception e) {
                                 m_promise.Reject(e);
                             }
                         }
                     }
                     class ArrayMapper<TSrc, TDst>: DispatchPool<int> {
                         readonly Func<TSrc, TDst> m_transform;
                         readonly TSrc[] m_source;
                         readonly TDst[] m_dest;
                         readonly Promise<TDst[]> m_promise = new Promise<TDst[]>();
                         readonly TraceContext m_traceContext;
                         int m_pending;
                         int m_next;
                         public ArrayMapper(TSrc[] source, Func<TSrc, TDst> transform, int threads)
                             : base(threads) {
                             Debug.Assert (source != null);
                             Debug.Assert( transform != null);
                             m_next = 0;
                             m_source = source;
                             m_dest = new TDst[source.Length];
                             m_pending = source.Length;
                             m_transform = transform;
                             m_traceContext = TraceContext.Snapshot();
                             m_promise.Anyway(() => Dispose());
                             m_promise.Cancelled(() => Dispose());
                             InitPool();
                         }
                         public Promise<TDst[]> Promise {
                             get {
                                 return m_promise;
                             }
                         }
                         protected override void Worker() {
                             TraceContext.Fork(m_traceContext);
                             base.Worker();
                         }
                         protected override bool TryDequeue(out int unit) {
                             unit = Interlocked.Increment(ref m_next) - 1;
                             return unit >= m_source.Length ? false : true;
                         }
                         protected override void InvokeUnit(int unit) {
                             try {
                                 m_dest[unit] = m_transform(m_source[unit]);
                                 var pending = Interlocked.Decrement(ref m_pending);
                                 if (pending == 0)
                                     m_promise.Resolve(m_dest);
                             } catch (Exception e) {
                                 m_promise.Reject(e);
                             }
                         }
                     }
                     public static IPromise<TDst[]> ParallelMap<TSrc, TDst> (this TSrc[] source, Func<TSrc,TDst> transform, int threads) {
                         if (source == null)
                             throw new ArgumentNullException("source");
                         if (transform == null)
                             throw new ArgumentNullException("transform");
                         var mapper = new ArrayMapper<TSrc, TDst>(source, transform, threads);
                         return mapper.Promise;
                     }
                     public static IPromise<int> ParallelForEach<TSrc>(this TSrc[] source, Action<TSrc> action, int threads) {
                         if (source == null)
                             throw new ArgumentNullException("source");
                         if (action == null)
                             throw new ArgumentNullException("action");
                         var iter = new ArrayIterator<TSrc>(source, action, threads);
                         return iter.Promise;
                     }
                     public static IPromise<TDst[]> ChainedMap<TSrc, TDst>(this TSrc[] source, ChainedOperation<TSrc, TDst> transform, int threads) {
                         if (source == null)
                             throw new ArgumentNullException("source");
                         if (transform == null)
                             throw new ArgumentNullException("transform");
                         if (threads <= 0)
                             throw new ArgumentOutOfRangeException("Threads number must be greater then zero");
                         if (source.Length == 0)
                             return Promise<TDst[]>.ResultToPromise(new TDst[0]);
                         var promise = new Promise<TDst[]>();
                         var res = new TDst[source.Length];
                         var pending = source.Length;
                         var semaphore = new Semaphore(threads, threads);
                         AsyncPool.InvokeNewThread(() => {
                             for (int i = 0; i < source.Length; i++) {
                                 if(promise.IsResolved)
                                     break; // stop processing in case of error or cancellation
                                 var idx = i;
                                 semaphore.WaitOne();
                                 try {
                                     var p1 = transform(source[i]);
                                     p1.Anyway(() => semaphore.Release());
                                     p1.Cancelled(() => semaphore.Release());
                                     p1.Then(
                                         x => {
                                             res[idx] = x;
                                             var left = Interlocked.Decrement(ref pending);
                                             if (left == 0)
                                                 promise.Resolve(res);
                                         },
-                                        e => promise.Reject(e)
+                                        e => {
+                                            promise.Reject(e);
+                                            throw new TransientPromiseException(e);
+                                        }
                                     );
                                 } catch (Exception e) {
                                     promise.Reject(e);
                                 }
                             }
                             return 0;
                         });
                         return promise.Anyway(() => semaphore.Dispose());
                     }
                 }
             }

Implab/Promise.cs +116 -147

             using System;
             using System.Collections.Generic;
             using System.Reflection;
             using System.Diagnostics;
             using System.Threading;
             using Implab.Parallels;
             namespace Implab {
                 public delegate void ErrorHandler(Exception e);
                 public delegate T ErrorHandler<out T>(Exception e);
                 public delegate void ResultHandler<in T>(T result);
                 public delegate TNew ResultMapper<in TSrc,out TNew>(TSrc result);
                 public delegate IPromise<TNew> ChainedOperation<in TSrc,TNew>(TSrc result);
                 /// <summary>
                 /// Класс для асинхронного получения результатов. Так называемое "обещание".
                 /// </summary>
                 /// <typeparam name="T">Тип получаемого результата</typeparam>
                 /// <remarks>
                 /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,
                 /// клиент получив такое обещание может установить ряд обратных вызово для получения
                 /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>
                 /// <para>
                 /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на
                 /// данные события клиент должен использовать методы <c>Then</c>.
                 /// </para>
                 /// <para>
                 /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),
                 /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о
                 /// выполнении обещания.
                 /// </para>
                 /// <para>
                 /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,
                 /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном
                 /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в
                 /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении
                 /// обещания.
                 /// </para>
                 /// <para>
                 /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать
                 /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует
                 /// использовать соответствующую форму методе <c>Then</c>.
                 /// </para>
                 /// <para>
                 /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать
                 /// только инициатор обещания иначе могут возникнуть противоречия.
                 /// </para>
                 /// </remarks>
                 public class Promise<T> : IPromise<T> {
                     protected struct HandlerDescriptor {
                         public ResultHandler<T> resultHandler;
-                        public ErrorHandler errorHandler;
+                        public ErrorHandler<T> errorHandler;
                         public Action cancellHandler;
+                        public Promise<T> medium;
                         public void Resolve(T result) {
-                            if (resultHandler != null)
+                            if (resultHandler != null) {
                                 try {
                                     resultHandler(result);
                                 } catch (Exception e) {
                                     Reject(e);
+                                    return;
                                 }
                             }
+                            if (medium != null)
+                                medium.Resolve(result);
+                        }
                         public void Reject(Exception err) {
-                            if (errorHandler != null)
+                            if (errorHandler != null) {
                                 try {
-                                    errorHandler(err);
+                                    var res = errorHandler(err);
-                                } catch {
+                                    if (medium != null)
+                                        medium.Resolve(res);
+                                } catch (TransientPromiseException err2) {
+                                    if (medium != null)
+                                        medium.Reject(err2.InnerException);
+                                } catch (Exception err2) {
+                                    if (medium != null)
+                                        medium.Reject(err2);
                                 }
+                            } else if (medium != null)
+                                medium.Reject(err);
                         }
                         public void Cancel() {
-                            if (cancellHandler != null)
+                            if (cancellHandler != null) {
                                 try {
                                     cancellHandler();
-                                } catch {
+                                } catch (Exception err) {
+                                    Reject(err);
+                                    return;
                                 }
                             }
+                            if (medium != null)
+                                medium.Cancel();
+                        }
                     }
                     const int UNRESOLVED_SATE = 0;
                     const int TRANSITIONAL_STATE = 1;
                     const int SUCCEEDED_STATE = 2;
                     const int REJECTED_STATE = 3;
                     const int CANCELLED_STATE = 4;
                     readonly bool m_cancellable;
                     int m_childrenCount = 0;
                     int m_state;
                     T m_result;
                     Exception m_error;
                     readonly MTQueue<HandlerDescriptor> m_handlers = new MTQueue<HandlerDescriptor>();
                     public Promise() {
                         m_cancellable = true;
                     }
                     public Promise(IPromise parent, bool cancellable) {
                         m_cancellable = cancellable;
                         if (parent != null)
-                            AddHandler(
+                            Cancelled(() => {
-                                null,
-                                null,
-                                () => {
                                 if (parent.IsExclusive)
                                     parent.Cancel();
+                            });
-                            );
                     }
                     bool BeginTransit() {
                         return UNRESOLVED_SATE == Interlocked.CompareExchange(ref m_state, TRANSITIONAL_STATE, UNRESOLVED_SATE);
                     }
                     void CompleteTransit(int state) {
                         if (TRANSITIONAL_STATE != Interlocked.CompareExchange(ref m_state, state, TRANSITIONAL_STATE))
                             throw new InvalidOperationException("Can't complete transition when the object isn't in the transitional state");
                     }
                     void WaitTransition() {
                         while (m_state == TRANSITIONAL_STATE) {
                             /* noop */
                         }
                     }
                     public bool IsResolved {
                         get {
                             return m_state > 1;
                         }
                     }
                     public bool IsCancelled {
                         get {
                             return m_state == CANCELLED_STATE;
                         }
                     }
                     public Type PromiseType {
                         get { return typeof(T); }
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об успешном выполнении.
                     /// </summary>
                     /// <param name="result">Результат выполнения.</param>
                     /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
                     public void Resolve(T result) {
                         if (BeginTransit()) {
                             m_result = result;
                             CompleteTransit(SUCCEEDED_STATE);
                             OnStateChanged();
                         } else {
                             WaitTransition();
                             if (m_state != CANCELLED_STATE)
                                 throw new InvalidOperationException("The promise is already resolved");
                         }
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об успешном выполнении. Результатом выполнения будет пустое значения.
                     /// </summary>
                     /// <remarks>
                     /// Данный вариант удобен в случаях, когда интересен факт выполнения операции, нежели полученное значение.
                     /// </remarks>
                     public void Resolve() {
                         Resolve(default(T));
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об ошибке
                     /// </summary>
                     /// <remarks>
                     /// Поскольку обещание должно работать в многопточной среде, при его выполнении сразу несколько потоков
                     /// могу вернуть ошибку, при этом только первая будет использована в качестве результата, остальные
                     /// будут проигнорированы.
                     /// </remarks>
                     /// <param name="error">Исключение возникшее при выполнении операции</param>
                     /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
                     public void Reject(Exception error) {
                         if (BeginTransit()) {
                             m_error = error;
                             CompleteTransit(REJECTED_STATE);
                             OnStateChanged();
                         } else {
                             WaitTransition();
                             if (m_state == SUCCEEDED_STATE)
                                 throw new InvalidOperationException("The promise is already resolved");
                         }
                     }
                     /// <summary>
                     /// Отменяет операцию, если это возможно.
                     /// </summary>
                     /// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>
                     public bool Cancel() {
-                        if (BeginTransit()) {
+                        if (m_cancellable && BeginTransit()) {
                             CompleteTransit(CANCELLED_STATE);
                             OnStateChanged();
                             return true;
-                        } else {
                         return false;
                     }
                     // сделано для возвращаемого типа void
                     protected void InternalCancel() {
                         Cancel();
                     }
                     /// <summary>
                     /// Adds new handlers to this promise.
                     /// </summary>
                     /// <param name="success">The handler of the successfully completed operation.
                     /// This handler will recieve an operation result as a parameter.</param>
-                    /// <param name="error">Handles an exception that may occur during the operation.</param>
-                    /// <returns>The new promise chained to this one.</returns>
-                    public IPromise<T> Then(ResultHandler<T> success, ErrorHandler error) {
-                        if (success == null && error == null)
-                            return this;
-                        var medium = new Promise<T>(this, true);
-                        ResultHandler<T> resultHandler;
-                        if (success != null)
-                            resultHandler = x => {
-                                success(x);
-                                medium.Resolve(x);
-                            };
-                        else
-                            resultHandler = medium.Resolve;
-                        ErrorHandler errorHandler;
-                        if (error != null)
-                            errorHandler = x => {
-                                // несмотря на то, что обработчик ошибки вызывается безопасно,
-                                // т.е. возникшие в нем ошибки будут подавлены, нам нужно
-                                // гарантировать, что ошибка будет передана дальше по цепочке обещаний
-                                try {
-                                    error(x);
-                                } catch { }
-                                medium.Reject(x);
-                            };
-                        else
-                            errorHandler = medium.Reject;
-                        AddHandler(resultHandler, errorHandler, medium.InternalCancel);
-                        return medium;
-                    public IPromise Then(Action success, ErrorHandler error) {
-                        return Then(x => success(), error);
-                    public IPromise Then(Action success) {
-                        return Then(x => success());
-                    /// <summary>
-                    /// Adds new handlers to this promise.
-                    /// </summary>
-                    /// <param name="success">The handler of the successfully completed operation.
-                    /// This handler will recieve an operation result as a parameter.</param>
                     /// <param name="error">Handles an exception that may occur during the operation and returns the value which will be used as the result of the operation.</param>
                     /// <returns>The new promise chained to this one.</returns>
                     public IPromise<T> Then(ResultHandler<T> success, ErrorHandler<T> error) {
                         if (success == null && error == null)
                             return this;
                         var medium = new Promise<T>(this, true);
-                        ResultHandler<T> resultHandler;
+                        AddHandler(success, error, null, medium);
-                        ErrorHandler errorHandler;
-                        if (success != null)
-                            resultHandler = x => {
-                                success(x);
-                                medium.Resolve(x);
-                            };
-                        else
-                            resultHandler = medium.Resolve;
-                        if (error != null)
-                            errorHandler = x => {
-                                try {
-                                    medium.Resolve(error(x));
-                                } catch (Exception e) {
-                                    medium.Reject(e);
-                            };
-                        else
-                            errorHandler = medium.Reject;
-                        AddHandler(resultHandler, errorHandler, medium.InternalCancel);
                         return medium;
                     }
+                    public IPromise Then(Action success, ErrorHandler error) {
+                        return Then(
+                            x => success(),
+                            e => {
+                                error(e);
+                                return default(T);
+                            }
+                        );
+                    }
+                    public IPromise Then(Action success) {
+                        return Then(x => success());
+                    }
                     public IPromise<T> Then(ResultHandler<T> success) {
                         if (success == null)
                             return this;
                         var medium = new Promise<T>(this, true);
-                        ResultHandler<T> resultHandler;
+                        AddHandler(success, null, null, medium);
-                        if (success != null)
-                            resultHandler = x => {
-                                success(x);
-                                medium.Resolve(x);
-                            };
-                        else
-                            resultHandler = medium.Resolve;
-                        AddHandler(resultHandler, medium.Reject, medium.InternalCancel);
                         return medium;
                     }
-                    public IPromise<T> Error(ErrorHandler error) {
+                    public IPromise Error(ErrorHandler error) {
-                        return Then((ResultHandler<T>)null, error);
+                        if (error == null)
+                            return this;
+                        var medium = new Promise<T>(this, true);
+                        AddHandler(
+                            null,
+                            e => {
+                                error(e);
+                                return default(T);
+                            },
+                            null,
+                            medium
+                        );
+                        return medium;
                     }
                     /// <summary>
                     /// Handles error and allows to keep the promise.
                     /// </summary>
                     /// <remarks>
                     /// If the specified handler throws an exception, this exception will be used to reject the promise.
                     /// </remarks>
                     /// <param name="handler">The error handler which returns the result of the promise.</param>
                     /// <returns>New promise.</returns>
                     public IPromise<T> Error(ErrorHandler<T> handler) {
                         if (handler == null)
                             return this;
                         var medium = new Promise<T>(this, true);
-                        AddHandler(
+                        AddHandler(null, handler, null, medium);
-                            x => medium.Resolve(x),
-                            e => {
-                                try {
-                                    medium.Resolve(handler(e));
-                                } catch (Exception e2) {
-                                    medium.Reject(e2);
-                            },
-                            medium.InternalCancel
-                        );
                         return medium;
                     }
                     public IPromise<T> Anyway(Action handler) {
                         if (handler == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(
-                            x => {
+                            x => handler(),
-                                // to avoid handler being called multiple times we handle exception by ourselfs
+                            e => {
-                                try {
                                 handler();
-                                    medium.Resolve(x);
+                                throw new TransientPromiseException(e);
-                                } catch (Exception e) {
-                                    medium.Reject(e);
                             },
+                            null,
-                            e => {
+                            medium
-                                try {
-                                    handler();
-                                } catch { }
-                                medium.Reject(e);
-                            },
-                            medium.InternalCancel
                         );
                         return medium;
                     }
                     /// <summary>
                     /// Позволяет преобразовать результат выполения операции к новому типу.
                     /// </summary>
                     /// <typeparam name="TNew">Новый тип результата.</typeparam>
                     /// <param name="mapper">Преобразование результата к новому типу.</param>
                     /// <param name="error">Обработчик ошибки. Данный обработчик получит
                     /// исключение возникшее при выполнении операции.</param>
                     /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
-                    public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler error) {
+                    public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler<T> error) {
                         if (mapper == null)
                             throw new ArgumentNullException("mapper");
                         // создаем прицепленное обещание
                         var chained = new Promise<TNew>(this, true);
                         ResultHandler<T> resultHandler = result => chained.Resolve(mapper(result));
-                        ErrorHandler errorHandler = delegate(Exception e) {
+                        ErrorHandler<T> errorHandler;
                         if (error != null)
+                            errorHandler = e => {
                                 try {
-                                    error(e);
+                                    return error(e);
-                                } catch { }
+                                } catch (Exception e2) {
                                     // в случае ошибки нужно передать исключение дальше по цепочке
+                                    chained.Reject(e2);
+                                }
+                                return default(T);
+                            };
+                        else
+                            errorHandler = e => {
                                 chained.Reject(e);
+                                return default(T);
                             };
                         AddHandler(
                             resultHandler,
                             errorHandler,
-                            chained.InternalCancel
+                            chained.InternalCancel,
+                            null
                         );
                         return chained;
                     }
                     public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {
                         return Map(mapper, null);
                     }
                     /// <summary>
                     /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
                     /// выполнения текущей, а результат текущей операции может быть использован для инициализации
                     /// новой операции.
                     /// </summary>
                     /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
                     /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
                     /// <param name="error">Обработчик ошибки. Данный обработчик получит
                     /// исключение возникшее при выполнении текуещй операции.</param>
                     /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
-                    public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler error) {
+                    public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler<T> error) {
                         // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
                         // создать посредника, к которому будут подвызяваться следующие обработчики.
                         // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
                         // передать через него результаты работы.
                         var medium = new Promise<TNew>(this, true);
                         ResultHandler<T> resultHandler = delegate(T result) {
                             if (medium.IsCancelled)
                                 return;
                             var promise = chained(result);
                             promise.Then(
-                                x => medium.Resolve(x),
+                                medium.Resolve,
-                                e => medium.Reject(e)
+                                err => {
+                                    medium.Reject(err);
+                                    throw new TransientPromiseException(err);
+                                }
                             );
                             // notify chained operation that it's not needed anymore
                             // порядок вызова Then, Cancelled важен, поскольку от этого
                             // зависит IsExclusive
                             medium.Cancelled(() => {
                                 if (promise.IsExclusive)
                                     promise.Cancel();
                             });
                             // внешняя отмена связанной операции рассматривается как ошибка
                             promise.Cancelled(() => medium.Reject(new OperationCanceledException()));
                         };
-                        ErrorHandler errorHandler = delegate(Exception e) {
+                        ErrorHandler<T> errorHandler = delegate(Exception e) {
-                            if (error != null)
+                            if (error != null) {
-                                error(e);
+                                try {
+                                    return error(e);
+                                } catch (Exception e2) {
+                                    medium.Reject(e2);
+                                    return default(T);
+                                }
+                            }
                             // в случае ошибки нужно передать исключение дальше по цепочке
                             medium.Reject(e);
+                            return default(T);
                         };
                         AddHandler(
                             resultHandler,
                             errorHandler,
-                            medium.InternalCancel
+                            medium.InternalCancel,
+                            null
                         );
                         return medium;
                     }
                     public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {
                         return Chain(chained, null);
                     }
                     public IPromise<T> Cancelled(Action handler) {
-                        AddHandler(null, null, handler);
+                        AddHandler(null, null, handler, null);
                         return this;
                     }
                     /// <summary>
                     /// Adds the specified handler for all cases (success, error, cancel)
                     /// </summary>
                     /// <param name="handler">The handler that will be called anyway</param>
                     /// <returns>self</returns>
                     public IPromise<T> Finally(Action handler) {
                         if (handler == null)
                             throw new ArgumentNullException("handler");
                         AddHandler(
                             x => handler(),
-                            e => handler(),
+                            e => {
-                            handler
+                                handler();
+                                throw new TransientPromiseException(e);
+                            },
+                            handler,
+                            null
                         );
                         return this;
                     }
                     /// <summary>
                     /// Преобразует результат обещания к нужному типу
                     /// </summary>
                     /// <typeparam name="T2"></typeparam>
                     /// <returns></returns>
                     public IPromise<T2> Cast<T2>() {
                         return Map(x => (T2)(object)x, null);
                     }
                     /// <summary>
                     /// Дожидается отложенного обещания и в случае успеха, возвращает
                     /// его, результат, в противном случае бросает исключение.
                     /// </summary>
                     /// <remarks>
                     /// <para>
                     /// Если ожидание обещания было прервано по таймауту, это не значит,
                     /// что обещание было отменено или что-то в этом роде, это только
                     /// означает, что мы его не дождались, однако все зарегистрированные
                     /// обработчики, как были так остались и они будут вызваны, когда
                     /// обещание будет выполнено.
                     /// </para>
                     /// <para>
                     /// Такое поведение вполне оправдано поскольку таймаут может истечь
                     /// в тот момент, когда началась обработка цепочки обработчиков, и
                     /// к тому же текущее обещание может стоять в цепочке обещаний и его
                     /// отклонение может привести к непрогнозируемому результату.
                     /// </para>
                     /// </remarks>
                     /// <param name="timeout">Время ожидания</param>
                     /// <returns>Результат выполнения обещания</returns>
                     public T Join(int timeout) {
                         var evt = new ManualResetEvent(false);
                         Anyway(() => evt.Set());
                         Cancelled(() => evt.Set());
                         if (!evt.WaitOne(timeout, true))
                             throw new TimeoutException();
                         switch (m_state) {
                             case SUCCEEDED_STATE:
                                 return m_result;
                             case CANCELLED_STATE:
                                 throw new OperationCanceledException();
                             case REJECTED_STATE:
                                 throw new TargetInvocationException(m_error);
                             default:
                                 throw new ApplicationException(String.Format("Invalid promise state {0}", m_state));
                         }
                     }
                     public T Join() {
                         return Join(Timeout.Infinite);
                     }
-                    void AddHandler(ResultHandler<T> success, ErrorHandler error, Action cancel) {
+                    void AddHandler(ResultHandler<T> success, ErrorHandler<T> error, Action cancel, Promise<T> medium) {
                         if (success != null || error != null)
                             Interlocked.Increment(ref m_childrenCount);
-                        HandlerDescriptor handler = new HandlerDescriptor {
+                        var handler = new HandlerDescriptor {
                             resultHandler = success,
                             errorHandler = error,
-                            cancellHandler = cancel
+                            cancellHandler = cancel,
+                            medium = medium
                         };
                         bool queued;
                         if (!IsResolved) {
                             m_handlers.Enqueue(handler);
                             queued = true;
                         } else {
                             // the promise is in resolved state, just invoke the handled with minimum overhead
                             queued = false;
                             InvokeHandler(handler);
                         }
                         if (queued && IsResolved && m_handlers.TryDequeue(out handler))
                             // if the promise have been resolved while we was adding handler to the queue
                             // we can't guarantee that someone is still processing it
                             // therefore we will fetch a handler from the queue and execute it
                             // note that fetched handler may be not the one that we have added
                             // even we can fetch no handlers at all :)
                             InvokeHandler(handler);
                     }
                     protected virtual void InvokeHandler(HandlerDescriptor handler) {
                         switch (m_state) {
                             case SUCCEEDED_STATE:
                                 handler.Resolve(m_result);
                                 break;
                             case REJECTED_STATE:
                                 handler.Reject(m_error);
                                 break;
                             case CANCELLED_STATE:
                                 handler.Cancel();
                                 break;
                             default:
                                 // do nothing
                                 return;
                         }
                     }
                     void OnStateChanged() {
                         HandlerDescriptor handler;
                         while (m_handlers.TryDequeue(out handler))
                             InvokeHandler(handler);
                     }
                     public bool IsExclusive {
                         get {
                             return m_childrenCount <= 1;
                         }
                     }
                     /// <summary>
                     /// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний.
                     /// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено.
                     /// При отмене нового обещания, переданные обещания также будут отменены, если никто больше на них не подписан.
                     /// </summary>
                     /// <param name="promises">Список обещаний. Если список пустой, то результирующее обещание возвращается уже выполненным.</param>
                     /// <returns>Обещание объединяющее в себе результат переданных обещаний.</returns>
                     /// <exception cref="ArgumentNullException"><paramref name="promises"/> не может быть null</exception>
                     public static IPromise<T[]> CreateComposite(IList<IPromise<T>> promises) {
                         if (promises == null)
                             throw new ArgumentNullException();
                         // создаем аккумулятор для результатов и результирующее обещание
                         var result = new T[promises.Count];
                         var promise = new Promise<T[]>();
                         // special case
                         if (promises.Count == 0) {
                             promise.Resolve(result);
                             return promise;
                         }
                         int pending = promises.Count;
                         for (int i = 0; i < promises.Count; i++) {
                             var dest = i;
                             if (promises[i] != null) {
                                 promises[i].Then(
                                     x => {
                                         result[dest] = x;
                                         if (Interlocked.Decrement(ref pending) == 0)
                                             promise.Resolve(result);
                                     },
-                                    e => promise.Reject(e)
+                                    e => {
+                                        promise.Reject(e);
+                                        return default(T);
+                                    }
                                 );
                             } else {
                                 if (Interlocked.Decrement(ref pending) == 0)
                                     promise.Resolve(result);
                             }
                         }
                         promise.Cancelled(
                             () => {
                                 foreach (var d in promises)
                                     if (d != null && d.IsExclusive)
                                         d.Cancel();
                             }
                         );
                         return promise;
                     }
                     /// <summary>
                     /// Объединяет несколько обещаний в одно. Результирующее обещание будет выполнено при
                     /// выполнении всех указанных обещаний. При этом возвращаемые значения первичных обещаний
                     /// игнорируются.
                     /// </summary>
                     /// <param name="promises">Коллекция первичных обещаний, которые будут объеденены в одно.</param>
                     /// <returns>Новое обещание, объединяющее в себе переданные.</returns>
                     /// <remarks>
                     /// Если в коллекции встречаюься <c>null</c>, то они воспринимаются как выполненные обещания.
                     /// </remarks>
                     public static IPromise CreateComposite(ICollection<IPromise> promises) {
                         if (promises == null)
                             throw new ArgumentNullException();
                         if (promises.Count == 0)
                             return Promise<object>.ResultToPromise(null);
                         int countdown = promises.Count;
                         var result = new Promise<object>();
                         foreach (var d in promises) {
                             if (d == null) {
                                 if (Interlocked.Decrement(ref countdown) == 0)
                                     result.Resolve(null);
                             } else {
                                 d.Then(() => {
                                     if (Interlocked.Decrement(ref countdown) == 0)
                                         result.Resolve(null);
                                 });
                             }
                         }
                         result.Cancelled(() => {
                             foreach (var d in promises)
                                 if (d != null && d.IsExclusive)
                                     d.Cancel();
                         });
                         return result;
                     }
                     public static Promise<T> ResultToPromise(T result) {
                         var p = new Promise<T>();
                         p.Resolve(result);
                         return p;
                     }
                     public static Promise<T> ExceptionToPromise(Exception error) {
                         if (error == null)
                             throw new ArgumentNullException();
                         var p = new Promise<T>();
                         p.Reject(error);
                         return p;
                     }
                     #region IPromiseBase explicit implementation
                     IPromise IPromise.Error(ErrorHandler error) {
                         return Error(error);
                     }
                     IPromise IPromise.Anyway(Action handler) {
                         return Anyway(handler);
                     }
                     IPromise IPromise.Finally(Action handler) {
                         return Finally(handler);
                     }
                     IPromise IPromise.Cancelled(Action handler) {
                         return Cancelled(handler);
                     }
                     void IPromise.Join() {
                         Join();
                     }
                     void IPromise.Join(int timeout) {
                         Join(timeout);
                     }
                     #endregion
                 }
             }

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages