implab/ImplabNet Commit - r151:ec91a6dfa5b3

Implab/PromiseAwaiter.cs created 644 +28 0

@@ -0,0 +1,28
	1	using System;
	2	using System.Runtime.CompilerServices;
	3
	4	namespace Implab {
	5	public struct PromiseAwaiter : INotifyCompletion {
	6	readonly IPromise m_promise;
	7
	8	public PromiseAwaiter(IPromise promise) {
	9	m_promise = promise;
	10	}
	11
	12	public void OnCompleted (Action continuation) {
	13	if (m_promise != null)
	14	m_promise.On(continuation, PromiseEventType.All);
	15	}
	16
	17	public void GetResult() {
	18	m_promise.Join();
	19	}
	20
	21	public bool IsCompleted {
	22	get {
	23	return m_promise.IsResolved;
	24	}
	25	}
	26	}
	27	}
	28

Implab/PromiseAwaiterT.cs created 644 +28 0

@@ -0,0 +1,28
	1	using System;
	2	using System.Runtime.CompilerServices;
	3
	4	namespace Implab {
	5	public struct PromiseAwaiter<T> : INotifyCompletion {
	6	readonly IPromise<T> m_promise;
	7
	8	public PromiseAwaiter(IPromise<T> promise) {
	9	m_promise = promise;
	10	}
	11
	12	public void OnCompleted (Action continuation) {
	13	if (m_promise != null)
	14	m_promise.On(continuation, PromiseEventType.All);
	15	}
	16
	17	public T GetResult() {
	18	return m_promise.Join();
	19	}
	20
	21	public bool IsCompleted {
	22	get {
	23	return m_promise.IsResolved;
	24	}
	25	}
	26	}
	27	}
	28

Implab.Fx/Implab.Fx.csproj +1 0

                 <AssemblyName>Implab.Fx</AssemblyName>
                 <TargetFrameworkVersion>v4.0</TargetFrameworkVersion>
                 <FileAlignment>512</FileAlignment>
+                <ReleaseVersion>0.2</ReleaseVersion>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>

Implab.Test/AsyncTests.cs +13 0

@@ -845,6 +845,19 namespace Implab.Test {
845	Console.WriteLine(m);	845	Console.WriteLine(m);
846	}	846	}
847	}	847	}
		848
		849	#if NET_4_5
		850
		851	[TestMethod]
		852	public async void TaskInteropTest() {
		853	var promise = new Promise<int>();
		854	promise.Resolve(10);
		855	var res = await promise;
		856
		857	Assert.AreEqual(10, res);
		858	}
		859
		860	#endif
848	}	861	}
849	}	862	}
850		863

Implab.Test/Implab.Test.mono.csproj +1 0

                 <RootNamespace>Implab.Test</RootNamespace>
                 <AssemblyName>Implab.Test</AssemblyName>
                 <TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
+                <ReleaseVersion>0.2</ReleaseVersion>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>

Implab.mono.sln +2 -1

             		{2BD05F84-E067-4B87-9477-FDC2676A21C6} = {BCA337C3-BFDC-4825-BBDB-E6D467E4E452}
             	EndGlobalSection
             	GlobalSection(MonoDevelopProperties) = preSolution
-            		StartupItem = MonoPlay\MonoPlay.csproj
             		Policies = $0
             		$0.CSharpFormattingPolicy = $1
             		$1.IndentSwitchBody = True
             		$34.NamingStyle = PascalCase
             		$34.IncludeInstanceMembers = True
             		$34.IncludeStaticEntities = True
+            		version = 0.2
+            		StartupItem = MonoPlay\MonoPlay.csproj
             	EndGlobalSection
             	GlobalSection(TestCaseManagementSettings) = postSolution
             		CategoryFile = Implab.vsmdi

Implab/IPromise.cs 0 -40

@@ -27,46 +27,6 namespace Implab {
27	Exception Error { get; }	27	Exception Error { get; }
28		28
29	/// <summary>	29	/// <summary>
30	/// Creates a new promise dependend on the current one and resolved on
31	/// executing the specified handlers.
32	/// </summary>
33	/// <param name="success">The handler called on the successful promise completion.</param>
34	/// <param name="error">The handler is called if an error while completing the promise occurred.</param>
35	/// <param name="cancel">The handler is called in case of promise cancellation.</param>
36	/// <returns>The newly created dependant promise.</returns>
37	/// <remarks>
38	/// <para>
39	/// If the success handler is specified the dependend promise will be resolved after the handler is
40	/// executed and the dependent promise will be linked to the current one, i.e. the cancellation
41	/// of the dependent property will lead to the cancellation of the current promise. If the
42	/// success handler isn't specified the dependent promise will not be linked to and
43	/// will not be resolved after the successfull resolution of the current one.
44	/// </para>
45	/// <para>
46	/// When the error handler is specified, the exception raised during the current promise completion
47	/// will be passed to it as the parameter. If the error handler returns without raising an
48	/// exception then the dependant promise will be resolved successfully, otherwise the exception
49	/// raised by the handler will be transmitted to the dependent promise. If the handler wants
50	/// to passthrough the original exception it needs to wrap the exception with
51	/// the <see cref="PromiseTransientException"/>. The handler may raise <see cref="OperationCanceledException"/>
52	/// to cancel the dependant promise, the innner exception specifies the reason why the promise
53	/// is canceled.
54	/// </para>
55	/// <para>
56	/// If the cancelation handler is specified and the current promise is cancelled then the dependent
57	/// promise will be resolved after the handler is executed. If the cancelation handler raises the
58	/// exception it will be passed to the dependent promise.
59	/// </para>
60	/// </remarks>
61	/* IPromise Then(Action success, Action<Exception> error, Action<Exception> cancel);
62	IPromise Then(Action success, Action<Exception> error);
63	IPromise Then(Action success);
64
65	IPromise Chain(Func<IPromise> chained, Func<Exception, IPromise> error, Func<Exception, IPromise> cancel);
66	IPromise Chain(Func<IPromise> chained, Func<Exception, IPromise> error);
67	IPromise Chain(Func<IPromise> chained);*/
68
69	/// <summary>
70	/// Adds specified listeners to the current promise.	30	/// Adds specified listeners to the current promise.
71	/// </summary>	31	/// </summary>
72	/// <param name="success">The handler called on the successful promise completion.</param>	32	/// <param name="success">The handler called on the successful promise completion.</param>

Implab/Implab.csproj +7 0

                 <OutputType>Library</OutputType>
                 <RootNamespace>Implab</RootNamespace>
                 <AssemblyName>Implab</AssemblyName>
+                <ProductVersion>8.0.30703</ProductVersion>
+                <SchemaVersion>2.0</SchemaVersion>
+                <ReleaseVersion>0.2</ReleaseVersion>
+                <TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
               <ItemGroup>
                 <Reference Include="System" />
                 <Reference Include="System.Xml" />
+                <Reference Include="mscorlib" />
               </ItemGroup>
               <ItemGroup>
                 <Compile Include="Component.cs" />
                 <Compile Include="ICancellationToken.cs" />
                 <Compile Include="SuccessPromise.cs" />
                 <Compile Include="SuccessPromiseT.cs" />
+                <Compile Include="PromiseAwaiterT.cs" />
+                <Compile Include="PromiseAwaiter.cs" />
               </ItemGroup>
               <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
               <ItemGroup />

Implab/PromiseExtensions.cs +2 -5

                     #if NET_4_5
-                    public static Task<T> GetTask<T>(this IPromise<T> that) {
+                    public static PromiseAwaiter<T> GetAwaiter<T>(this IPromise<T> that) {
                         Safe.ArgumentNotNull(that, "that");
-                        var tcs = new TaskCompletionSource<T>();
-                        that.On(tcs.SetResult, tcs.SetException, r => tcs.SetCanceled());
+                        return new PromiseAwaiter<T>(that);
-                        return tcs.Task;
                     }
                     #endif

MonoPlay/MonoPlay.csproj +1 0

                 <RootNamespace>MonoPlay</RootNamespace>
                 <AssemblyName>MonoPlay</AssemblyName>
                 <TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
+                <ReleaseVersion>0.2</ReleaseVersion>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>

MonoPlay/Program.cs +10 -13

             using System.Threading;
             using Implab.JSON;
             using System.IO;
+            using System.Threading.Tasks;
             namespace MonoPlay {
                 class MainClass {
                         var t1 = Environment.TickCount;
-                        for(int i =0; i < 1000000; i++)
+                        DoWork().GetAwaiter().GetResult();
-                        using (var tw = new StringWriter()) {
-                            var jw = new JSONWriter(tw);
-                            jw.WriteValue("\r\nhere\tvalue\u0002\u0003");
-                            //Console.WriteLine(tw);
                         var t2 = Environment.TickCount;
                         Console.WriteLine("done: {0} ms, {1:.00} Mb, {2} GC", t2 - t1, GC.GetTotalMemory(false) / (1024*1024), GC.CollectionCount(0) );
                     }
-                    static void DoTest() {
+                    static IPromise<int> DoItem(int x) {
+                        return Promise<int>.FromResult(x + 1);
+                    }
+                    static async Task<int> DoWork() {
+                        var c = 0;
+                        for (int i = 0; i < 10000000; i++)
+                            c = await DoItem(c);
+                        return c;
                     }
                 }

	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