removed setting RPC inspector in WithMessageIdFunction()

onflow · Jan 5, 2023 · 11bb5a8 · 11bb5a8
1 parent 84550e5
commit 11bb5a8
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/insecure/corruptlibp2p/pubsub_adapter_config.go b/insecure/corruptlibp2p/pubsub_adapter_config.go
@@ -83,12 +83,6 @@ func (c *CorruptPubSubAdapterConfig) WithAppSpecificRpcInspector(_ func(peer.ID,
 }
 
 func (c *CorruptPubSubAdapterConfig) WithMessageIdFunction(f func([]byte) string) {
-	if c.inspector != nil {
-		c.options = append(c.options, corrupt.WithAppSpecificRpcInspector(func(id peer.ID, rpc *corrupt.RPC) error {
-			return c.inspector(id, rpc)
-		}))
-	}
-
 	c.options = append(c.options, corrupt.WithMessageIdFn(func(pmsg *pb.Message) string {
 		return f(pmsg.Data)
 	}))