diff options
| author | Janoš Guljaš <janos@users.noreply.github.com> | 2018-09-28 14:34:29 +0800 |
|---|---|---|
| committer | Martin Holst Swende <martin@swende.se> | 2018-09-28 14:34:29 +0800 |
| commit | d8d86692716158f9d514dcaa06b69f129d43c3d8 (patch) | |
| tree | ccfbcfd996a357e723be36557df036bc5497ad76 | |
| parent | e39a9b3480af0ac8044294f46e0e9e4c3948d23c (diff) | |
| download | dexon-d8d86692716158f9d514dcaa06b69f129d43c3d8.tar dexon-d8d86692716158f9d514dcaa06b69f129d43c3d8.tar.gz dexon-d8d86692716158f9d514dcaa06b69f129d43c3d8.tar.bz2 dexon-d8d86692716158f9d514dcaa06b69f129d43c3d8.tar.lz dexon-d8d86692716158f9d514dcaa06b69f129d43c3d8.tar.xz dexon-d8d86692716158f9d514dcaa06b69f129d43c3d8.tar.zst dexon-d8d86692716158f9d514dcaa06b69f129d43c3d8.zip | |
swarm/network/stream: fix streamer test compilation issue (#17772)
| -rw-r--r-- | swarm/network/stream/streamer_test.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/swarm/network/stream/streamer_test.go b/swarm/network/stream/streamer_test.go index ba4328eef..0390a7b9b 100644 --- a/swarm/network/stream/streamer_test.go +++ b/swarm/network/stream/streamer_test.go @@ -477,9 +477,9 @@ func TestStreamerDownstreamCorruptHashesMsgExchange(t *testing.T) { return tc, nil }) - peerID := tester.IDs[0] + node := tester.Nodes[0] - err = streamer.Subscribe(peerID, stream, NewRange(5, 8), Top) + err = streamer.Subscribe(node.ID(), stream, NewRange(5, 8), Top) if err != nil { t.Fatalf("Expected no error, got %v", err) } @@ -494,7 +494,7 @@ func TestStreamerDownstreamCorruptHashesMsgExchange(t *testing.T) { History: NewRange(5, 8), Priority: Top, }, - Peer: peerID, + Peer: node.ID(), }, }, }, @@ -512,7 +512,7 @@ func TestStreamerDownstreamCorruptHashesMsgExchange(t *testing.T) { To: 8, Stream: stream, }, - Peer: peerID, + Peer: node.ID(), }, }, }) @@ -521,7 +521,7 @@ func TestStreamerDownstreamCorruptHashesMsgExchange(t *testing.T) { } 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) } } |