remove peer filter check from subscriptions (#453)

This commit is contained in:
Simon Zhu 2021-09-22 00:46:09 -07:00 committed by GitHub
parent 628353661b
commit 7ef0669764
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -1001,10 +1001,6 @@ func (p *PubSub) handleIncomingRPC(rpc *RPC) {
for _, subopt := range subs {
t := subopt.GetTopicid()
if !p.peerFilter(rpc.from, t) {
continue
}
if subopt.GetSubscribe() {
tmap, ok := p.topics[t]
if !ok {