Yamux setaccepter
This commit is contained in:
parent
66775873c7
commit
e96524f702
@ -49,6 +49,7 @@ func (p *peerService) Init(a *app.App) (err error) {
|
|||||||
p.pool = a.MustComponent(pool.CName).(pool.Pool)
|
p.pool = a.MustComponent(pool.CName).(pool.Pool)
|
||||||
p.server = a.MustComponent(server.CName).(server.DRPCServer)
|
p.server = a.MustComponent(server.CName).(server.DRPCServer)
|
||||||
p.peerAddrs = map[string][]string{}
|
p.peerAddrs = map[string][]string{}
|
||||||
|
p.yamux.SetAccepter(p)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user