Pubsub: fix apply()
RPC: fix apply()
bench: add various pubsub benchmarks