Upgrade structure of code base
This commit is contained in:
@@ -1,36 +1,13 @@
|
||||
using Enigmos.Exceptions;
|
||||
using Enigmos.Modules.ControllingModules;
|
||||
using Enigmos.Ports.DataPorts;
|
||||
using Nocturnis.Enigmos.Modules;
|
||||
using Nocturnis.Enigmos.Ports.DataPorts.Directions;
|
||||
|
||||
namespace Enigmos.Modules.TerminalModules;
|
||||
|
||||
public abstract partial class TerminalModule : BaseModule
|
||||
public abstract partial class TerminalModule : BaseModule, ITerminalModule
|
||||
{
|
||||
public bool Finished { get; set; }
|
||||
public IDataInPort[] DataInPorts { get; set; } = Array.Empty<IDataInPort>();
|
||||
|
||||
protected virtual void Consume(RootModule root)
|
||||
{
|
||||
foreach (DataInPort port in Ports.OfType<DataInPort>())
|
||||
port.GetData(root);
|
||||
Finished = true;
|
||||
}
|
||||
public virtual void Drain() => Finished = true;
|
||||
}
|
||||
|
||||
public void ConsumeWithTimeoutHandle(RootModule root)
|
||||
{
|
||||
try
|
||||
{
|
||||
Finished = true;
|
||||
Consume(root);
|
||||
}
|
||||
catch (ModuleExecutionTimeout timeout)
|
||||
{
|
||||
TimeoutHandler(timeout);
|
||||
}
|
||||
}
|
||||
|
||||
protected override void TimeoutHandler(ModuleExecutionTimeout timeout)
|
||||
{
|
||||
Finished = false;
|
||||
base.TimeoutHandler(timeout);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user