aboutsummaryrefslogtreecommitdiffstats
path: root/rpc/packages_test.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2015-02-20 19:59:54 +0800
committerobscuren <geffobscura@gmail.com>2015-02-20 19:59:54 +0800
commit982f73fa6d6f12874729faacd0db14fc78d518dd (patch)
tree9234eea5a981d73985c6127d5a1ea1cc09cce151 /rpc/packages_test.go
parent000658539136645e743d83d57a8106b2a9796b93 (diff)
downloadgo-tangerine-982f73fa6d6f12874729faacd0db14fc78d518dd.tar.gz
go-tangerine-982f73fa6d6f12874729faacd0db14fc78d518dd.tar.zst
go-tangerine-982f73fa6d6f12874729faacd0db14fc78d518dd.zip
Added timeout for filter & removed clipboard. Closes #350
Diffstat (limited to 'rpc/packages_test.go')
-rw-r--r--rpc/packages_test.go37
1 files changed, 37 insertions, 0 deletions
diff --git a/rpc/packages_test.go b/rpc/packages_test.go
new file mode 100644
index 000000000..037fd78b3
--- /dev/null
+++ b/rpc/packages_test.go
@@ -0,0 +1,37 @@
+package rpc
+
+import (
+ "sync"
+ "testing"
+ "time"
+)
+
+func TestFilterClose(t *testing.T) {
+ api := &EthereumApi{
+ logs: make(map[int]*logFilter),
+ messages: make(map[int]*whisperFilter),
+ quit: make(chan struct{}),
+ }
+
+ filterTickerTime = 1
+ api.logs[0] = &logFilter{}
+ api.messages[0] = &whisperFilter{}
+ var wg sync.WaitGroup
+ wg.Add(1)
+ go api.start()
+ go func() {
+ select {
+ case <-time.After(500 * time.Millisecond):
+ api.stop()
+ wg.Done()
+ }
+ }()
+ wg.Wait()
+ if len(api.logs) != 0 {
+ t.Error("expected logs to be empty")
+ }
+
+ if len(api.messages) != 0 {
+ t.Error("expected messages to be empty")
+ }
+}