diff options
| author | Viktor Trón <viktor.tron@gmail.com> | 2018-10-12 22:26:16 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-10-12 22:26:16 +0800 |
| commit | 6566a0a3b82f5d24d478d3876d5fa2b1b0e8684c (patch) | |
| tree | 52f31f4bc541ed6bf9643bef11ceefd75e831d0e /swarm/network/stream/delivery_test.go | |
| parent | dc3c3fb1e177c5d01ae3ca63717130eea924271e (diff) | |
| download | go-tangerine-6566a0a3b82f5d24d478d3876d5fa2b1b0e8684c.tar go-tangerine-6566a0a3b82f5d24d478d3876d5fa2b1b0e8684c.tar.gz go-tangerine-6566a0a3b82f5d24d478d3876d5fa2b1b0e8684c.tar.bz2 go-tangerine-6566a0a3b82f5d24d478d3876d5fa2b1b0e8684c.tar.lz go-tangerine-6566a0a3b82f5d24d478d3876d5fa2b1b0e8684c.tar.xz go-tangerine-6566a0a3b82f5d24d478d3876d5fa2b1b0e8684c.tar.zst go-tangerine-6566a0a3b82f5d24d478d3876d5fa2b1b0e8684c.zip | |
swarm/network/stream: generalise setting of next batch (#17818)
* swarm/network/stream: generalize SetNextBatch and add Server SessionIndex
* swarm/network/stream: fix a typo in comment
* swarm/network/stream: remove live argument from NewSwarmSyncerServer
Diffstat (limited to 'swarm/network/stream/delivery_test.go')
| -rw-r--r-- | swarm/network/stream/delivery_test.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/swarm/network/stream/delivery_test.go b/swarm/network/stream/delivery_test.go index b021b8771..c6ebae3f0 100644 --- a/swarm/network/stream/delivery_test.go +++ b/swarm/network/stream/delivery_test.go @@ -88,7 +88,7 @@ func TestStreamerUpstreamRetrieveRequestMsgExchangeWithoutStore(t *testing.T) { peer := streamer.getPeer(node.ID()) peer.handleSubscribeMsg(context.TODO(), &SubscribeMsg{ - Stream: NewStream(swarmChunkServerStreamName, "", false), + Stream: NewStream(swarmChunkServerStreamName, "", true), History: nil, Priority: Top, }) @@ -136,7 +136,7 @@ func TestStreamerUpstreamRetrieveRequestMsgExchange(t *testing.T) { node := tester.Nodes[0] peer := streamer.getPeer(node.ID()) - stream := NewStream(swarmChunkServerStreamName, "", false) + stream := NewStream(swarmChunkServerStreamName, "", true) peer.handleSubscribeMsg(context.TODO(), &SubscribeMsg{ Stream: stream, @@ -409,7 +409,7 @@ func testDeliveryFromNodes(t *testing.T, nodes, conns, chunkCount int, skipCheck return fmt.Errorf("No registry") } registry := item.(*Registry) - err = registry.Subscribe(sid, NewStream(swarmChunkServerStreamName, "", false), NewRange(0, 0), Top) + err = registry.Subscribe(sid, NewStream(swarmChunkServerStreamName, "", true), NewRange(0, 0), Top) if err != nil { return err } |