diff options
author | Jeffrey Wilcke <obscuren@users.noreply.github.com> | 2014-07-07 16:59:16 +0800 |
---|---|---|
committer | Jeffrey Wilcke <obscuren@users.noreply.github.com> | 2014-07-07 16:59:16 +0800 |
commit | 6fe9b4ab5e839be96eb1c4a619bc14fab622d8d1 (patch) | |
tree | b8b1218e456d3daaad4a36e6ba022323c3762038 /ethutil/reactor_test.go | |
parent | 9dab7dcc3c99d387ad2c0a1623b574d3023bdfae (diff) | |
download | dexon-6fe9b4ab5e839be96eb1c4a619bc14fab622d8d1.tar.gz dexon-6fe9b4ab5e839be96eb1c4a619bc14fab622d8d1.tar.zst dexon-6fe9b4ab5e839be96eb1c4a619bc14fab622d8d1.zip |
Revert "ethreact - Feature/ethutil refactor"
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") + } +} |