opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-02 03:28:25 +08:00
Code Issues Projects Releases Wiki Activity

style(bitswap) public methods at top

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-12-23 07:07:19 -05:00
committed by Juan Batiz-Benet
parent 4ab4da7e2b
commit a225568ff6
1 changed files with 23 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
exchange/bitswap/network/ipfs_impl.go
View File

@ -30,29 +30,6 @@ type impl struct {
receiver Receiver receiver Receiver
} }
// handleNewStream receives a new stream from the network.
func (bsnet *impl) handleNewStream(s inet.Stream) {
if bsnet.receiver == nil {
return
}
go func() {
defer s.Close()
received, err := bsmsg.FromNet(s)
if err != nil {
go bsnet.receiver.ReceiveError(err)
return
}
p := s.Conn().RemotePeer()
ctx := context.Background()
bsnet.receiver.ReceiveMessage(ctx, p, received)
}()
}
func (bsnet *impl) DialPeer(ctx context.Context, p peer.ID) error { func (bsnet *impl) DialPeer(ctx context.Context, p peer.ID) error {
return bsnet.network.DialPeer(ctx, p) return bsnet.network.DialPeer(ctx, p)
} }
@ -92,3 +69,26 @@ func (bsnet *impl) SendRequest(
func (bsnet *impl) SetDelegate(r Receiver) { func (bsnet *impl) SetDelegate(r Receiver) {
bsnet.receiver = r bsnet.receiver = r
} }
// handleNewStream receives a new stream from the network.
func (bsnet *impl) handleNewStream(s inet.Stream) {
if bsnet.receiver == nil {
return
}
go func() {
defer s.Close()
received, err := bsmsg.FromNet(s)
if err != nil {
go bsnet.receiver.ReceiveError(err)
return
}
p := s.Conn().RemotePeer()
ctx := context.Background()
bsnet.receiver.ReceiveMessage(ctx, p, received)
}()
}