Add standalone Observable.OnSubscribe<RemoteEvent>

It will allow running cluster nodes as separate threads in a single JVM
process.