aboutsummaryrefslogtreecommitdiffstats
path: root/ethutil/reactor.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-03-03 18:35:35 +0800
committerobscuren <geffobscura@gmail.com>2014-03-03 18:35:35 +0800
commit5b1613d65b0c3471b80990120022b5a745ecab86 (patch)
treeaddbb87cc82cca07e8ac8aa810d810e1de02b2a5 /ethutil/reactor.go
parentd7c5936ac4ee8ae3156e0bc9813db61b990aa686 (diff)
parentc1d0ea7366f1bad134c985dbe1f272d376e5ec9b (diff)
downloaddexon-5b1613d65b0c3471b80990120022b5a745ecab86.tar.gz
dexon-5b1613d65b0c3471b80990120022b5a745ecab86.tar.zst
dexon-5b1613d65b0c3471b80990120022b5a745ecab86.zip
Merge branch 'master' into develop
Diffstat (limited to 'ethutil/reactor.go')
-rw-r--r--ethutil/reactor.go86
1 files changed, 86 insertions, 0 deletions
diff --git a/ethutil/reactor.go b/ethutil/reactor.go
new file mode 100644
index 000000000..f8084986c
--- /dev/null
+++ b/ethutil/reactor.go
@@ -0,0 +1,86 @@
+package ethutil
+
+import (
+ "sync"
+)
+
+type ReactorEvent struct {
+ mut sync.Mutex
+ event string
+ chans []chan React
+}
+
+// Post the specified reactor resource on the channels
+// currently subscribed
+func (e *ReactorEvent) Post(react React) {
+ e.mut.Lock()
+ defer e.mut.Unlock()
+
+ for _, ch := range e.chans {
+ go func(ch chan React) {
+ ch <- react
+ }(ch)
+ }
+}
+
+// Add a subscriber to this event
+func (e *ReactorEvent) Add(ch chan React) {
+ e.mut.Lock()
+ defer e.mut.Unlock()
+
+ e.chans = append(e.chans, ch)
+}
+
+// Remove a subscriber
+func (e *ReactorEvent) Remove(ch chan React) {
+ e.mut.Lock()
+ defer e.mut.Unlock()
+
+ for i, c := range e.chans {
+ if c == ch {
+ e.chans = append(e.chans[:i], e.chans[i+1:]...)
+ }
+ }
+}
+
+// Basic reactor resource
+type React struct {
+ Resource interface{}
+}
+
+// The reactor basic engine. Acts as bridge
+// between the events and the subscribers/posters
+type ReactorEngine struct {
+ patterns map[string]*ReactorEvent
+}
+
+func NewReactorEngine() *ReactorEngine {
+ return &ReactorEngine{patterns: make(map[string]*ReactorEvent)}
+}
+
+// Subscribe a channel to the specified event
+func (reactor *ReactorEngine) Subscribe(event string, ch chan React) {
+ ev := reactor.patterns[event]
+ // Create a new event if one isn't available
+ if ev == nil {
+ ev = &ReactorEvent{event: event}
+ reactor.patterns[event] = ev
+ }
+
+ // Add the channel to reactor event handler
+ ev.Add(ch)
+}
+
+func (reactor *ReactorEngine) Unsubscribe(event string, ch chan React) {
+ ev := reactor.patterns[event]
+ if ev != nil {
+ ev.Remove(ch)
+ }
+}
+
+func (reactor *ReactorEngine) Post(event string, resource interface{}) {
+ ev := reactor.patterns[event]
+ if ev != nil {
+ ev.Post(React{Resource: resource})
+ }
+}