Change fix for Apply in SwitchC.

SodiumFRP · Jan 31, 2018 · c1b2aa0 · c1b2aa0
1 parent f0cf4f6
commit c1b2aa0
Showing 1 changed file with 9 additions and 8 deletions.
diff --git a/c#/src/Sodium/Sodium/Transaction.cs b/c#/src/Sodium/Sodium/Transaction.cs
@@ -343,17 +343,18 @@ internal void Send(Action<Transaction> action)
 
  internal void Prioritized(Node node, Action<Transaction> action)
  {
- Entry e = new Entry(node, action);
- lock (Node.NodeRanksLock)
+ if (this.finishedPriorityQueue)
  {
- this.prioritizedQueue.Enqueue(e, node.Rank);
+ this.lastQueue.Add(() => action(this));
  }
- this.entries.Add(e);
-
- // we have already processed all prioritized items, so run the action now
- if (this.finishedPriorityQueue)
+ else
  {
- action(this);
+ Entry e = new Entry(node, action);
+ lock (Node.NodeRanksLock)
+ {
+ this.prioritizedQueue.Enqueue(e, node.Rank);
+ }
+ this.entries.Add(e);
  }
  }