swarm/stream: fix failing test

This commit is contained in:
Martin Holst Swende 2018-09-27 20:46:11 +02:00
parent e39a9b3480
commit 4ccd42c0b4
No known key found for this signature in database
GPG key ID: 683B438C05A5DDF0

View file

@ -477,7 +477,7 @@ func TestStreamerDownstreamCorruptHashesMsgExchange(t *testing.T) {
return tc, nil return tc, nil
}) })
peerID := tester.IDs[0] peerID := tester.Nodes[0].ID()
err = streamer.Subscribe(peerID, stream, NewRange(5, 8), Top) err = streamer.Subscribe(peerID, stream, NewRange(5, 8), Top)
if err != nil { if err != nil {
@ -521,7 +521,7 @@ func TestStreamerDownstreamCorruptHashesMsgExchange(t *testing.T) {
} }
expectedError := errors.New("Message handler error: (msg code 1): error invalid hashes length (len: 40)") expectedError := errors.New("Message handler error: (msg code 1): error invalid hashes length (len: 40)")
if err := tester.TestDisconnected(&p2ptest.Disconnect{Peer: tester.IDs[0], Error: expectedError}); err != nil { if err := tester.TestDisconnected(&p2ptest.Disconnect{Peer: tester.Nodes[0].ID(), Error: expectedError}); err != nil {
t.Fatal(err) t.Fatal(err)
} }
} }