From d727a75e6debe3e7c1f1bbd14fe2204825101ae1 Mon Sep 17 00:00:00 2001 From: Steven Allen Date: Tue, 17 Oct 2017 15:58:27 -0700 Subject: [PATCH] NewStream now creates a connection if necessary License: MIT Signed-off-by: Steven Allen --- exchange/bitswap/network/ipfs_impl.go | 8 -------- 1 file changed, 8 deletions(-) diff --git a/exchange/bitswap/network/ipfs_impl.go b/exchange/bitswap/network/ipfs_impl.go index e96d74447..3b7c87312 100644 --- a/exchange/bitswap/network/ipfs_impl.go +++ b/exchange/bitswap/network/ipfs_impl.go @@ -105,14 +105,6 @@ func (bsnet *impl) NewMessageSender(ctx context.Context, p peer.ID) (MessageSend } func (bsnet *impl) newStreamToPeer(ctx context.Context, p peer.ID) (inet.Stream, error) { - - // first, make sure we're connected. - // if this fails, we cannot connect to given peer. - //TODO(jbenet) move this into host.NewStream? - if err := bsnet.host.Connect(ctx, pstore.PeerInfo{ID: p}); err != nil { - return nil, err - } - return bsnet.host.NewStream(ctx, p, ProtocolBitswap, ProtocolBitswapOne, ProtocolBitswapNoVers) }