1 files changed, 41 insertions, 0 deletions
diff --git a/pkg/events/events.go b/pkg/events/events.go
new file mode 100755
index 00000000..226a0c91
--- /dev/null
+++ b/pkg/events/events.go
@@ -0,0 +1,41 @@
+package events
+
+import (
+	"sync"
+
+	"github.com/spiral/roadrunner/v2/interfaces/events"
+)
+
+// HandlerImpl helps to broadcast events to multiple listeners.
+type HandlerImpl struct {
+	listeners    []events.Listener
+	sync.RWMutex // all receivers should be pointers
+}
+
+func NewEventsHandler() events.Handler {
+	return &HandlerImpl{listeners: make([]events.Listener, 0, 2)}
+}
+
+// NumListeners returns number of event listeners.
+func (eb *HandlerImpl) NumListeners() int {
+	eb.Lock()
+	defer eb.Unlock()
+	return len(eb.listeners)
+}
+
+// AddListener registers new event listener.
+func (eb *HandlerImpl) AddListener(listener events.Listener) {
+	eb.Lock()
+	defer eb.Unlock()
+	eb.listeners = append(eb.listeners, listener)
+}
+
+// Push broadcast events across all event listeners.
+func (eb *HandlerImpl) Push(e interface{}) {
+	// ReadLock here because we are not changing listeners
+	eb.RLock()
+	defer eb.RUnlock()
+	for k := range eb.listeners {
+		eb.listeners[k](e)
+	}
+}