Skip to content

Commit

Permalink
remove peer filter check from subscriptions
Browse files Browse the repository at this point in the history
  • Loading branch information
synzhu committed Sep 22, 2021
1 parent 6283536 commit 58f2052
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions pubsub.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 58f2052

Please sign in to comment.