pubsub with rpc-stream and EventEmitter2