Reimplement load balancing using Observable.lift(). Rename some APIs to indicate command pattern.