aboutsummaryrefslogtreecommitdiff
path: root/xmpp-vala/src/module/util.vala
diff options
context:
space:
mode:
authorfiaxh <git@mx.ax.lt>2018-01-19 22:37:02 +0100
committerfiaxh <git@mx.ax.lt>2018-01-28 13:37:53 +0100
commit57c72d2818dec6c713834cfbb8c4c566a1602907 (patch)
tree0f7102171049cce6f6732b658d005b3c57140271 /xmpp-vala/src/module/util.vala
parentca331e85efe2a74a6b9b5a5ff0fbcd10a36758ce (diff)
downloaddino-57c72d2818dec6c713834cfbb8c4c566a1602907.tar.gz
dino-57c72d2818dec6c713834cfbb8c4c566a1602907.zip
Pipeline for incoming messages in libdino
Diffstat (limited to 'xmpp-vala/src/module/util.vala')
-rw-r--r--xmpp-vala/src/module/util.vala47
1 files changed, 28 insertions, 19 deletions
diff --git a/xmpp-vala/src/module/util.vala b/xmpp-vala/src/module/util.vala
index 1043dee1..02f391ae 100644
--- a/xmpp-vala/src/module/util.vala
+++ b/xmpp-vala/src/module/util.vala
@@ -12,34 +12,42 @@ public string random_uuid() {
return "%08x-%04x-%04x-%04x-%04x%08x".printf(b1, b2, b3, b4, b5_1, b5_2);
}
-public abstract class StanzaListener<T> : Object {
+public abstract class StanzaListener<T> : OrderedListener {
+
+ public abstract async bool run(XmppStream stream, T stanza);
+}
+
+public class StanzaListenerHolder<T> : ListenerHolder {
+
+ public async void run(XmppStream stream, T stanza) {
+ foreach (OrderedListener ol in listeners) {
+ StanzaListener<T> l = ol as StanzaListener<T>;
+ bool stop = yield l.run(stream, stanza);
+ if (stop) break;
+ }
+ }
+}
+
+public abstract class OrderedListener : Object {
public abstract string action_group { get; }
public abstract string[] after_actions { get; }
-
- public abstract async void run(XmppStream stream, T stanza);
}
-public class StanzaListenerHolder<T> : Object {
- private ArrayList<StanzaListener<T>> listeners = new ArrayList<StanzaListener<T>>();
+public abstract class ListenerHolder : Object {
+ protected ArrayList<OrderedListener> listeners = new ArrayList<OrderedListener>();
- public new void connect(StanzaListener<T> listener) {
+ public new void connect(OrderedListener listener) {
listeners.add(listener);
resort_list();
}
- public new void disconnect(StanzaListener<T> listener) {
+ public new void disconnect(OrderedListener listener) {
listeners.remove(listener);
resort_list();
}
- public async void run(XmppStream stream, T stanza) {
- foreach (StanzaListener<T> l in listeners) {
- yield l.run(stream, stanza);
- }
- }
-
- private bool set_contains_action(Gee.List<StanzaListener<T>> s, string[] actions) {
- foreach (StanzaListener<T> l in s) {
+ private bool set_contains_action(Gee.List<OrderedListener> s, string[] actions) {
+ foreach(OrderedListener l in s) {
if (l.action_group in actions) {
return true;
}
@@ -48,22 +56,23 @@ public class StanzaListenerHolder<T> : Object {
}
private void resort_list() {
- ArrayList<StanzaListener<T>> new_list = new ArrayList<StanzaListener<T>>();
- ArrayList<StanzaListener<T>> remaining = new ArrayList<StanzaListener<T>>();
+ ArrayList<OrderedListener> new_list = new ArrayList<OrderedListener>();
+ ArrayList<OrderedListener> remaining = new ArrayList<OrderedListener>();
remaining.add_all(listeners);
while (remaining.size > 0) {
bool changed = false;
- Gee.Iterator<StanzaListener<T>> iter = remaining.iterator();
+ Gee.Iterator<OrderedListener> iter = remaining.iterator();
while (iter.has_next()) {
if (!iter.valid) {
iter.next();
}
- StanzaListener<T> l = iter.get();
+ OrderedListener l = iter.get();
if (!set_contains_action(remaining, l.after_actions)) {
new_list.add(l);
iter.remove();
changed = true;
}
+ iter.next();
}
if (!changed) error("Can't sort listeners");
}