pex_reactor.go
func (r *PEXReactor) OnStart() error {
	r.BaseReactor.OnStart()
	r.book.Start()
	go r.ensurePeersRoutine()
	go r.flushMsgCountByPeer()
	return nil
}
func (r *PEXReactor) OnStart() error {
	r.BaseReactor.OnStart()
	r.book.Start()
	go r.ensurePeersRoutine()
	go r.flushMsgCountByPeer()
	return nil
}
func ( r * PEXReactor ) OnStart ( ) error { r . BaseReactor . OnStart ( ) r . book . Start ( ) go r . ensurePeersRoutine ( ) go r . flushMsgCountByPeer ( ) return nil }
// OnStart implements BaseService
OnStart implements BaseService