aboutsummaryrefslogtreecommitdiffstats
path: root/ethutil/reactor_test.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_test.go
parentd7c5936ac4ee8ae3156e0bc9813db61b990aa686 (diff)
parentc1d0ea7366f1bad134c985dbe1f272d376e5ec9b (diff)
downloaddexon-5b1613d65b0c3471b80990120022b5a745ecab86.tar
dexon-5b1613d65b0c3471b80990120022b5a745ecab86.tar.gz
dexon-5b1613d65b0c3471b80990120022b5a745ecab86.tar.bz2
dexon-5b1613d65b0c3471b80990120022b5a745ecab86.tar.lz
dexon-5b1613d65b0c3471b80990120022b5a745ecab86.tar.xz
dexon-5b1613d65b0c3471b80990120022b5a745ecab86.tar.zst
dexon-5b1613d65b0c3471b80990120022b5a745ecab86.zip
Merge branch 'master' into develop
Diffstat (limited to 'ethutil/reactor_test.go')
-rw-r--r--ethutil/reactor_test.go30
1 files changed, 30 insertions, 0 deletions
diff --git a/ethutil/reactor_test.go b/ethutil/reactor_test.go
new file mode 100644
index 000000000..48c2f0df3
--- /dev/null
+++ b/ethutil/reactor_test.go
@@ -0,0 +1,30 @@
+package ethutil
+
+import "testing"
+
+func TestReactorAdd(t *testing.T) {
+ engine := NewReactorEngine()
+ ch := make(chan React)
+ engine.Subscribe("test", ch)
+ if len(engine.patterns) != 1 {
+ t.Error("Expected patterns to be 1, got", len(engine.patterns))
+ }
+}
+
+func TestReactorEvent(t *testing.T) {
+ engine := NewReactorEngine()
+
+ // Buffer 1, so it doesn't block for this test
+ ch := make(chan React, 1)
+ engine.Subscribe("test", ch)
+ engine.Post("test", "hello")
+
+ value := <-ch
+ if val, ok := value.Resource.(string); ok {
+ if val != "hello" {
+ t.Error("Expected Resource to be 'hello', got", val)
+ }
+ } else {
+ t.Error("Unable to cast")
+ }
+}