remove unnecessary task dispatch

Author: Simn

src/hxcoro/task/CoroBaseTask.hx

@@ -1,24 +1,21 @@
 package hxcoro.task;
 
-import hxcoro.continuations.FunctionContinuation;
-import hxcoro.concurrent.AtomicState;
-import hxcoro.concurrent.AtomicObject;
-import hxcoro.concurrent.BackOff;
-import hxcoro.elements.NonCancellable;
-import hxcoro.task.CoroTask;
-import hxcoro.task.node.INodeStrategy;
-import hxcoro.task.ICoroTask;
-import hxcoro.task.AbstractTask;
-import hxcoro.task.ICoroNode;
 import haxe.Exception;
-import haxe.exceptions.CancellationException;
 import haxe.coro.IContinuation;
+import haxe.coro.cancellation.CancellationToken;
 import haxe.coro.context.Context;
-import haxe.coro.context.Key;
 import haxe.coro.context.IElement;
-import haxe.coro.dispatchers.Dispatcher;
-import haxe.coro.cancellation.CancellationToken;
+import haxe.coro.context.Key;
+import haxe.exceptions.CancellationException;
+import hxcoro.concurrent.AtomicObject;
 import hxcoro.concurrent.ThreadSafeCallbacks;
+import hxcoro.continuations.FunctionContinuation;
+import hxcoro.elements.NonCancellable;
+import hxcoro.task.AbstractTask;
+import hxcoro.task.CoroTask;
+import hxcoro.task.ICoroNode;
+import hxcoro.task.ICoroTask;
+import hxcoro.task.node.INodeStrategy;
 
 class TaskContinuationManager extends ThreadSafeCallbacks<IContinuation<Any>, IContinuation<Any>, IContinuation<Any>> {
 	public function new(task:CoroBaseTask<Any>) {
@@ -85,9 +82,7 @@ abstract class CoroBaseTask<T> extends AbstractTask implements ICoroNode impleme
 		Creates a child task to execute `lambda` and starts it automatically.
 	**/
 	public function async<T>(lambda:NodeLambda<T>):ICoroTask<T> {
-		final child = new CoroTaskWithLambda<T>(context, lambda, CoroTask.CoroChildStrategy);
-		context.get(Dispatcher).dispatch(child);
-		return child;
+		return new CoroTaskWithLambda<T>(context, lambda, CoroTask.CoroChildStrategy);
 	}
 
 	/**

src/hxcoro/task/CoroTask.hx

@@ -1,15 +1,14 @@
 package hxcoro.task;
 
+import haxe.Exception;
+import haxe.coro.IContinuation;
+import haxe.coro.context.Context;
+import hxcoro.task.AbstractTask;
+import hxcoro.task.ICoroTask;
 import hxcoro.task.node.CoroChildStrategy;
 import hxcoro.task.node.CoroScopeStrategy;
 import hxcoro.task.node.CoroSupervisorStrategy;
 import hxcoro.task.node.INodeStrategy;
-import hxcoro.task.AbstractTask;
-import hxcoro.task.ICoroTask;
-import haxe.coro.IContinuation;
-import haxe.coro.context.Context;
-import haxe.coro.dispatchers.IDispatchObject;
-import haxe.Exception;
 
 @:using(CoroTask.ResumeStatusTools)
 private enum abstract ResumeStatus(Int) to Int {
@@ -64,7 +63,7 @@ class CoroTask<T> extends CoroBaseTask<T> implements IContinuation<T> {
 	#end
 }
 
-class CoroTaskWithLambda<T> extends CoroTask<T> implements IDispatchObject implements IStartableCoroTask<T> {
+class CoroTaskWithLambda<T> extends CoroTask<T> implements IStartableCoroTask<T> {
 	final lambda:NodeLambda<T>;
 
 	/**
@@ -75,10 +74,6 @@ class CoroTaskWithLambda<T> extends CoroTask<T> implements IDispatchObject imple
 		super(context, nodeStrategy, initialState);
 	}
 
-	public function onDispatch() {
-		start();
-	}
-
 	/**
 		Starts executing this task's `lambda`. Has no effect if the task is already active or has completed.
 	**/

src/hxcoro/util/Convenience.hx

@@ -1,8 +1,5 @@
 package hxcoro.util;
 
-import hxcoro.task.CoroTask;
-import hxcoro.task.ICoroTask;
-import hxcoro.task.NodeLambda;
 import haxe.Exception;
 import haxe.Int64;
 import haxe.coro.IContinuation;
@@ -13,6 +10,9 @@ import haxe.coro.dispatchers.Dispatcher;
 import haxe.coro.dispatchers.IDispatchObject;
 import haxe.exceptions.CancellationException;
 import hxcoro.continuations.FunctionContinuation;
+import hxcoro.task.CoroTask;
+import hxcoro.task.ICoroTask;
+import hxcoro.task.NodeLambda;
 
 private class FunctionDispatchObject implements IDispatchObject {
 	final func : ()->Void;
@@ -130,9 +130,7 @@ class ContextConvenience {
 	}
 
 	static public function async<T>(context:Context, lambda:NodeLambda<T>):ICoroTask<T> {
-		final child = new CoroTaskWithLambda<T>(context, lambda, CoroTask.CoroChildStrategy);
-		context.get(Dispatcher).dispatch(child);
-		return child;
+		return new CoroTaskWithLambda<T>(context, lambda, CoroTask.CoroChildStrategy);
 	}
 
 	static public function lazy<T>(context:Context, lambda:NodeLambda<T>):IStartableCoroTask<T> {