mirror of
https://github.com/ipfs/kubo.git
synced 2026-03-05 16:28:06 +08:00
feat(bitswap:msg) add ToNet() method
This commit is contained in:
parent
2f4175a00d
commit
24224979bb
@ -2,6 +2,7 @@ package bitswap
|
||||
|
||||
import (
|
||||
blocks "github.com/jbenet/go-ipfs/blocks"
|
||||
nm "github.com/jbenet/go-ipfs/net/message"
|
||||
swarm "github.com/jbenet/go-ipfs/net/swarm"
|
||||
peer "github.com/jbenet/go-ipfs/peer"
|
||||
u "github.com/jbenet/go-ipfs/util"
|
||||
@ -36,3 +37,7 @@ func (m *message) ToProto() *PBMessage {
|
||||
func (m *message) ToSwarm(p *peer.Peer) *swarm.Message {
|
||||
return swarm.NewMessage(p, m.ToProto())
|
||||
}
|
||||
|
||||
func (m *message) ToNet(p *peer.Peer) (nm.NetMessage, error) {
|
||||
return nm.FromObject(p, m.ToProto())
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user