diff options
author | obscuren <geffobscura@gmail.com> | 2014-03-03 18:35:35 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-03-03 18:35:35 +0800 |
commit | 5b1613d65b0c3471b80990120022b5a745ecab86 (patch) | |
tree | addbb87cc82cca07e8ac8aa810d810e1de02b2a5 /ethutil/reactor_test.go | |
parent | d7c5936ac4ee8ae3156e0bc9813db61b990aa686 (diff) | |
parent | c1d0ea7366f1bad134c985dbe1f272d376e5ec9b (diff) | |
download | dexon-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.go | 30 |
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") + } +} |