diff options
author | Felix Lange <fjl@twurst.com> | 2014-10-14 08:18:12 +0800 |
---|---|---|
committer | Felix Lange <fjl@twurst.com> | 2014-10-17 00:51:21 +0800 |
commit | ade980912da4afb7d92f845b8d41955851791dc9 (patch) | |
tree | cf372a2db9ab9fe5bc1534ab223f74e1336a7e2d /ethreact/reactor_test.go | |
parent | 28570ef109d6a0f66e419165c985509bb01dc6bd (diff) | |
download | dexon-ade980912da4afb7d92f845b8d41955851791dc9.tar dexon-ade980912da4afb7d92f845b8d41955851791dc9.tar.gz dexon-ade980912da4afb7d92f845b8d41955851791dc9.tar.bz2 dexon-ade980912da4afb7d92f845b8d41955851791dc9.tar.lz dexon-ade980912da4afb7d92f845b8d41955851791dc9.tar.xz dexon-ade980912da4afb7d92f845b8d41955851791dc9.tar.zst dexon-ade980912da4afb7d92f845b8d41955851791dc9.zip |
ethreact: remove package
Diffstat (limited to 'ethreact/reactor_test.go')
-rw-r--r-- | ethreact/reactor_test.go | 63 |
1 files changed, 0 insertions, 63 deletions
diff --git a/ethreact/reactor_test.go b/ethreact/reactor_test.go deleted file mode 100644 index 801a8abd0..000000000 --- a/ethreact/reactor_test.go +++ /dev/null @@ -1,63 +0,0 @@ -package ethreact - -import ( - "fmt" - "testing" -) - -func TestReactorAdd(t *testing.T) { - reactor := New() - ch := make(chan Event) - reactor.Subscribe("test", ch) - if reactor.eventHandlers["test"] == nil { - t.Error("Expected new eventHandler to be created") - } - reactor.Unsubscribe("test", ch) - if reactor.eventHandlers["test"] != nil { - t.Error("Expected eventHandler to be removed") - } -} - -func TestReactorEvent(t *testing.T) { - var name string - reactor := New() - // Buffer the channel, so it doesn't block for this test - cap := 20 - ch := make(chan Event, cap) - reactor.Subscribe("even", ch) - reactor.Subscribe("odd", ch) - reactor.Post("even", "disappears") // should not broadcast if engine not started - reactor.Start() - for i := 0; i < cap; i++ { - if i%2 == 0 { - name = "even" - } else { - name = "odd" - } - reactor.Post(name, i) - } - reactor.Post("test", cap) // this should not block - i := 0 - reactor.Flush() - close(ch) - for event := range ch { - fmt.Printf("%d: %v", i, event) - if i%2 == 0 { - name = "even" - } else { - name = "odd" - } - if val, ok := event.Resource.(int); ok { - if i != val || event.Name != name { - t.Error("Expected event %d to be of type %s and resource %d, got ", i, name, i, val) - } - } else { - t.Error("Unable to cast") - } - i++ - } - if i != cap { - t.Error("excpected exactly %d events, got ", i) - } - reactor.Stop() -} |