dkanus/Acedia
Archived
1
0
Fork 0
Code Issues 1 Pull Requests Releases Wiki Activity

Add events ability to start/shutdown Service

Browse Source 
Events might rely on a particular `Service` to generate them,
this patch allows them to auto-launch/shutdown a service, depending on
whether anybody is listening to it's events.
This commit is contained in:
Anton Tarasenko 2020-07-18 02:21:23 +07:00
parent 5a14bb6d2c
commit 6125289040
1 changed files with 31 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
sources/Core/Events/Events.uc
View File

@ -70,6 +70,13 @@ var private array< class<Listener> > listeners;
var public const class<Listener> relatedListener; var public const class<Listener> relatedListener;
// Even class can also auto-spawn a `Service`,
// in case it's require to generate events
var public const class<Service> connectedServiceClass;
// Set this to `true`if you want `connectedServiceClass` service to also
// auto-shutdown whenever no-one listens to the events.
var public const bool shutDownServiceWithoutListeners;
static public final function array< class<Listener> > GetListeners() static public final function array< class<Listener> > GetListeners()
{ {
return default.listeners; return default.listeners;
@ -83,10 +90,15 @@ static public final function bool ActivateListener(class<Listener> newListener)
if (newListener == none) return false; if (newListener == none) return false;
if (!ClassIsChildOf(newListener, default.relatedListener)) return false; if (!ClassIsChildOf(newListener, default.relatedListener)) return false;
// Spawn service, if absent
if ( default.listeners.length == 0
&& default.connectedServiceClass != none) {
default.connectedServiceClass.static.Require();
}
// Add listener
for (i = 0;i < default.listeners.length;i += 1) for (i = 0;i < default.listeners.length;i += 1)
{ {
if (default.listeners[i] == newListener) if (default.listeners[i] == newListener) {
{
return false; return false;
} }
} }
@ -99,17 +111,31 @@ static public final function bool ActivateListener(class<Listener> newListener)
static public final function bool DeactivateListener(class<Listener> listener) static public final function bool DeactivateListener(class<Listener> listener)
{ {
local int i; local int i;
local bool removedListener;
local Service service;
if (listener == none) return false; if (listener == none) return false;
// Remove listener
for (i = 0; i < default.listeners.length; i += 1) for (i = 0; i < default.listeners.length; i += 1)
{ {
if (default.listeners[i] == listener) if (default.listeners[i] == listener)
{ {
default.listeners.Remove(i, 1); default.listeners.Remove(i, 1);
return true; removedListener = true;
break;
} }
} }
return false; // Remove unneeded service
if ( default.shutDownServiceWithoutListeners
&& default.listeners.length == 0
&& default.connectedServiceClass != none)
{
service = Service(default.connectedServiceClass.static.GetInstance());
if (service != none) {
service.Destroy();
}
}
return removedListener;
} }
static public final function bool IsActiveListener(class<Listener> listener) static public final function bool IsActiveListener(class<Listener> listener)