From e9ea621b93fbb58d9edfca8375918791637bbd52 Mon Sep 17 00:00:00 2001
From: chai <chaifix@163.com>
Date: Wed, 30 Dec 2020 20:59:04 +0800
Subject: +init

---
 .../Events/Register/TemporaryEventRegister.cs      | 59 ++++++++++++++++++++++
 1 file changed, 59 insertions(+)
 create mode 100644 Impostor-dev/src/Impostor.Server/Events/Register/TemporaryEventRegister.cs

(limited to 'Impostor-dev/src/Impostor.Server/Events/Register/TemporaryEventRegister.cs')

diff --git a/Impostor-dev/src/Impostor.Server/Events/Register/TemporaryEventRegister.cs b/Impostor-dev/src/Impostor.Server/Events/Register/TemporaryEventRegister.cs
new file mode 100644
index 0000000..1446ad1
--- /dev/null
+++ b/Impostor-dev/src/Impostor.Server/Events/Register/TemporaryEventRegister.cs
@@ -0,0 +1,59 @@
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Threading;
+
+namespace Impostor.Server.Events.Register
+{
+    internal class TemporaryEventRegister
+    {
+        private readonly ConcurrentDictionary<int, IRegisteredEventListener> _callbacks;
+        private int _idLast;
+
+        public TemporaryEventRegister()
+        {
+            _callbacks = new ConcurrentDictionary<int, IRegisteredEventListener>();
+        }
+
+        public IEnumerable<IRegisteredEventListener> GetEventListeners()
+        {
+            return _callbacks.Select(i => i.Value);
+        }
+
+        public IDisposable Add(IRegisteredEventListener callback)
+        {
+            var id = Interlocked.Increment(ref _idLast);
+
+            if (!_callbacks.TryAdd(id, callback))
+            {
+                Debug.Fail("Failed to register the event listener");
+            }
+
+            return new UnregisterEvent(this, id);
+        }
+
+        private void Remove(int id)
+        {
+            _callbacks.TryRemove(id, out _);
+        }
+
+        private class UnregisterEvent : IDisposable
+        {
+            private readonly TemporaryEventRegister _register;
+            private readonly int _id;
+
+            public UnregisterEvent(TemporaryEventRegister register, int id)
+            {
+                _register = register;
+                _id = id;
+            }
+
+            public void Dispose()
+            {
+                _register.Remove(_id);
+            }
+        }
+    }
+}
\ No newline at end of file
-- 
cgit v1.1-26-g67d0