Ellpeck/Coroutine
1
0
Fork 0
mirror of https://github.com/Ellpeck/Coroutine.git synced 2024-11-21 13:23:29 +01:00
Code Issues Projects Releases Wiki Activity

allow querying finish states of coroutines

Browse source
This commit is contained in:
Ellpeck 2020-02-28 22:27:38 +01:00
parent 0642b84085
commit d6ad4e1f2c
3 changed files with 23 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
Coroutine/Coroutine.cs → Coroutine/ActiveCoroutine.cs
View file

@ -1,34 +1,35 @@
using System.Collections.Generic;
namespace Coroutine {
internal struct Coroutine {
public class ActiveCoroutine {
private readonly IEnumerator<IWait> enumerator;
public bool IsFinished { get; private set; }
public Coroutine(IEnumerator<IWait> enumerator) {
internal ActiveCoroutine(IEnumerator<IWait> enumerator) {
this.enumerator = enumerator;
this.enumerator.MoveNext();
}
public bool Tick(double deltaSeconds) {
internal bool Tick(double deltaSeconds) {
var curr = this.enumerator.Current;
if (curr != null && curr.Tick(deltaSeconds)) {
if (!this.enumerator.MoveNext())
return true;
this.IsFinished = true;
}
return false;
return this.IsFinished;
}
public bool OnEvent(Event evt) {
internal bool OnEvent(Event evt) {
var curr = this.enumerator.Current;
if (curr != null && curr.OnEvent(evt)) {
if (!this.enumerator.MoveNext())
return true;
this.IsFinished = true;
}
return false;
return this.IsFinished;
}
public WaitType GetCurrentType() {
internal WaitType GetCurrentType() {
return this.enumerator.Current.GetWaitType();
}

9
Coroutine/CoroutineHandler.cs
View file

@ -4,16 +4,17 @@ using System.Collections.Generic;
namespace Coroutine {
public static class CoroutineHandler {
private static readonly List<Coroutine> TickingCoroutines = new List<Coroutine>();
private static readonly List<Coroutine> EventCoroutines = new List<Coroutine>();
private static readonly List<ActiveCoroutine> TickingCoroutines = new List<ActiveCoroutine>();
private static readonly List<ActiveCoroutine> EventCoroutines = new List<ActiveCoroutine>();
public static void Start(IEnumerator<IWait> coroutine) {
var inst = new Coroutine(coroutine);
public static ActiveCoroutine Start(IEnumerator<IWait> coroutine) {
var inst = new ActiveCoroutine(coroutine);
var type = inst.GetCurrentType();
if (type == WaitType.Tick)
TickingCoroutines.Add(inst);
else if (type == WaitType.Event)
EventCoroutines.Add(inst);
return inst;
}
public static void InvokeLater(IWait wait, Action action) {

13
Test/Example.cs
View file

@ -9,8 +9,8 @@ namespace Test {
private static readonly Event TestEvent = new Event();
public static void Main() {
CoroutineHandler.Start(WaitSeconds());
CoroutineHandler.Start(PrintEvery5Seconds());
var seconds = CoroutineHandler.Start(WaitSeconds());
CoroutineHandler.Start(PrintEvery10Seconds(seconds));
CoroutineHandler.InvokeLater(new WaitSeconds(10), () => {
Console.WriteLine("Raising test event");
@ -39,14 +39,17 @@ namespace Test {
Console.WriteLine("After 10 more seconds " + DateTime.Now);
yield return new WaitSeconds(20);
Console.WriteLine("Done");
Environment.Exit(0);
Console.WriteLine("First coroutine done");
}
private static IEnumerator<IWait> PrintEvery5Seconds() {
private static IEnumerator<IWait> PrintEvery10Seconds(ActiveCoroutine first) {
while (true) {
yield return new WaitSeconds(10);
Console.WriteLine("The time is " + DateTime.Now);
if (first.IsFinished) {
Console.WriteLine("By the way, the first coroutine has finished!");
Environment.Exit(0);
}
}
}