aboutsummaryrefslogtreecommitdiffstats
path: root/swarm/network/stream/common_test.go
diff options
context:
space:
mode:
authorElad <theman@elad.im>2019-01-25 00:23:34 +0800
committerRafael Matias <rafael@skyle.net>2019-02-19 19:56:31 +0800
commit2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0 (patch)
tree597df951ae6ea5389bdb26b7199c9a299a155acb /swarm/network/stream/common_test.go
parente247dcc141a5d1c9129b987a5f164e9df29be951 (diff)
downloaddexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar
dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.gz
dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.bz2
dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.lz
dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.xz
dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.tar.zst
dexon-2695aa9e0d09e58817d2560ecdbd7b5b67f8f1b0.zip
p2p/testing, swarm: remove unused testing.T in protocol tester (#18500)
(cherry picked from commit 2abeb35d5425d72c2f7fdfe4209f7a94fac52a8e)
Diffstat (limited to 'swarm/network/stream/common_test.go')
-rw-r--r--swarm/network/stream/common_test.go5
1 files changed, 2 insertions, 3 deletions
diff --git a/swarm/network/stream/common_test.go b/swarm/network/stream/common_test.go
index 29b917d39..7b2962608 100644
--- a/swarm/network/stream/common_test.go
+++ b/swarm/network/stream/common_test.go
@@ -27,7 +27,6 @@ import (
"os"
"strings"
"sync/atomic"
- "testing"
"time"
"github.com/ethereum/go-ethereum/log"
@@ -67,7 +66,7 @@ func init() {
log.Root().SetHandler(log.LvlFilterHandler(log.Lvl(*loglevel), log.StreamHandler(colorable.NewColorableStderr(), log.TerminalFormat(true))))
}
-func newStreamerTester(t *testing.T, registryOptions *RegistryOptions) (*p2ptest.ProtocolTester, *Registry, *storage.LocalStore, func(), error) {
+func newStreamerTester(registryOptions *RegistryOptions) (*p2ptest.ProtocolTester, *Registry, *storage.LocalStore, func(), error) {
// setup
addr := network.RandomAddr() // tested peers peer address
to := network.NewKademlia(addr.OAddr, network.NewKadParams())
@@ -102,7 +101,7 @@ func newStreamerTester(t *testing.T, registryOptions *RegistryOptions) (*p2ptest
streamer.Close()
removeDataDir()
}
- protocolTester := p2ptest.NewProtocolTester(t, addr.ID(), 1, streamer.runProtocol)
+ protocolTester := p2ptest.NewProtocolTester(addr.ID(), 1, streamer.runProtocol)
err = waitForPeers(streamer, 1*time.Second, 1)
if err != nil {