floodsub: gx imports

License: MIT
Signed-off-by: Jeromy <[email protected]>

core/commands/pubsub.go

@@ -4,12 +4,11 @@ import (
 	"bytes"
 	"fmt"
 	"io"
-	"reflect"
-
-	u "gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
 
 	cmds "github.com/ipfs/go-ipfs/commands"
-	floodsub "github.com/whyrusleeping/go-floodsub"
+
+	floodsub "gx/ipfs/QmTP5RSsmZacEFanuBhnDE3RC3aqGAoozF9ZmKqcHa8EKH/floodsub"
+	u "gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util"
 )
 
 var PubsubCmd = &cmds.Command{
@@ -71,7 +70,6 @@ var PubsubSubCmd = &cmds.Command{
 		cmds.Text: func(res cmds.Response) (io.Reader, error) {
 			outChan, ok := res.Output().(<-chan interface{})
 			if !ok {
-				fmt.Println(reflect.TypeOf(res.Output()))
 				return nil, u.ErrCast()
 			}
 

core/core.go

@@ -17,12 +17,12 @@ import (
 	"time"
 
 	diag "github.com/ipfs/go-ipfs/diagnostics"
-	floodsub "github.com/whyrusleeping/go-floodsub"
 	goprocess "gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess"
 	mamask "gx/ipfs/QmSMZwvs3n4GBikZ7hKzT17c3bk65FmyZo2JqtJ16swqCv/multiaddr-filter"
 	pstore "gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore"
 	logging "gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log"
 	b58 "gx/ipfs/QmT8rehPR3F6bmwL6zjUN8XpiDBFFpMP2myPdC6ApsWfJf/go-base58"
+	floodsub "gx/ipfs/QmTP5RSsmZacEFanuBhnDE3RC3aqGAoozF9ZmKqcHa8EKH/floodsub"
 	ic "gx/ipfs/QmVoi5es8D5fNHZDqoW6DgDAEPEV5hQp8GBz161vZXiwpQ/go-libp2p-crypto"
 	peer "gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer"
 	ma "gx/ipfs/QmYzDkkgAEmrcNzFCiYo6L1dTX4EAG1gZkbtdbd9trL4vd/go-multiaddr"

package.json

@@ -233,6 +233,12 @@
       "hash": "QmUHmMGmcwCrjHQHcYhBnqGCSWs5pBSMbGZmfwavETR1gg",
       "name": "go-ds-leveldb",
       "version": "1.0.0"
+    },
+    {
+      "author": "whyrusleeping",
+      "hash": "QmTP5RSsmZacEFanuBhnDE3RC3aqGAoozF9ZmKqcHa8EKH",
+      "name": "floodsub",
+      "version": "0.2.0"
     }
   ],
   "gxVersion": "0.4.0",