From 1bad77c7db35e99f194875317d1a1fb2264d93d7 Mon Sep 17 00:00:00 2001 From: Jeromy Date: Thu, 3 Nov 2016 14:56:23 -0700 Subject: [PATCH] update packages to add support for getStreams --- p2p/net/mock/mock_conn.go | 8 ++++++++ p2p/test/reconnects/reconnect_test.go | 2 +- package.json | 28 +++++++++++++-------------- 3 files changed, 23 insertions(+), 15 deletions(-) diff --git a/p2p/net/mock/mock_conn.go b/p2p/net/mock/mock_conn.go index a552c7e..ae90cdd 100644 --- a/p2p/net/mock/mock_conn.go +++ b/p2p/net/mock/mock_conn.go @@ -118,6 +118,14 @@ func (c *conn) NewStream() (inet.Stream, error) { return s, nil } +func (c *conn) GetStreams() ([]inet.Stream, error) { + var out []inet.Stream + for e := c.streams.Front(); e != nil; e = e.Next() { + out = append(out, e.Value.(*stream)) + } + return out, nil +} + // LocalMultiaddr is the Multiaddr on this side func (c *conn) LocalMultiaddr() ma.Multiaddr { return c.localAddr diff --git a/p2p/test/reconnects/reconnect_test.go b/p2p/test/reconnects/reconnect_test.go index b72081e..ed3ed97 100644 --- a/p2p/test/reconnects/reconnect_test.go +++ b/p2p/test/reconnects/reconnect_test.go @@ -10,12 +10,12 @@ import ( u "github.com/ipfs/go-ipfs-util" logging "github.com/ipfs/go-log" - ps "github.com/jbenet/go-peerstream" host "github.com/libp2p/go-libp2p-host" inet "github.com/libp2p/go-libp2p-net" protocol "github.com/libp2p/go-libp2p-protocol" swarm "github.com/libp2p/go-libp2p-swarm" testutil "github.com/libp2p/go-libp2p/p2p/test/util" + ps "github.com/libp2p/go-peerstream" ) func init() { diff --git a/package.json b/package.json index e04a321..695a86b 100644 --- a/package.json +++ b/package.json @@ -114,9 +114,9 @@ "version": "0.0.0" }, { - "hash": "QmRmFKJgjjQhrT1uDyhpS87kE5M9YbMT8RBWam5uk8o4uH", + "hash": "QmS9en3mcwW2HRSeRabceJEGVxTZF4vEeFm7JHWQwWsb1U", "name": "go-peerstream", - "version": "1.1.0" + "version": "1.4.1" }, { "author": "whyrusleeping", @@ -210,39 +210,39 @@ }, { "author": "whyrusleeping", - "hash": "QmdiBXu57LDzaoovc89jypRSNEhxVZ4zRig2AsXm9VwrsS", + "hash": "QmU1YMnktAuCPBC7TqhbZRkpZ7KCiekv7SZtaLU5zpTgqb", "name": "go-libp2p-conn", - "version": "1.2.1" + "version": "1.4.0" }, { "author": "whyrusleeping", - "hash": "QmdXimY9QHaasZmw6hWojWnCJvfgxETjZQfg9g6ZrA9wMX", + "hash": "QmdysBu77i3YaagNtMAjiCJdeWWvds18ho5XEB784guQ41", "name": "go-libp2p-net", - "version": "1.2.1" + "version": "1.5.0" }, { "author": "whyrusleeping", - "hash": "QmWpTXhTkpoCDEm9twJd5Rc9jFwy61emzxneeJzrVMfjGF", + "hash": "QmVcNzHewFvmVah1CGqg8NV7nHHsPu19U43YE5b2oqWyBp", "name": "go-libp2p-metrics", - "version": "1.2.0" + "version": "1.5.0" }, { "author": "whyrusleeping", - "hash": "QmNxScD426NivSWRNJdLVfXLrzVdtNWxW74EnXAWJvgGwh", + "hash": "QmctX4TY6jXtpfeDiwMGoB4qVTBGDnz7T7r22CwQSzTgwt", "name": "go-libp2p-interface-conn", - "version": "0.1.2" + "version": "0.4.0" }, { "author": "whyrusleeping", - "hash": "QmdML3R42PRSwnt46jSuEts9bHSqLctVYEjJqMR3UYV8ki", + "hash": "QmWf338UyG5DKyemvoFiomDPtkVNHLsw3GAt9XXHX5ZtsM", "name": "go-libp2p-host", - "version": "1.1.0" + "version": "1.1.1" }, { "author": "whyrusleeping", - "hash": "QmTsTADtVpWhp2CYpAqDJWYSK94gMzhE77mQKbp18oC4PK", + "hash": "QmYe8b7yWBaaE4bxoG9UB1pvSYkcXnNAMP664iJfnvH4i5", "name": "go-libp2p-swarm", - "version": "1.2.0" + "version": "1.3.2" }, { "author": "whyrusleeping", -- GitLab