Replace ExecutionService with rx.Schedule.Worker

rx.Schedule.Worker run on a background thread inside the EventSink so
unsubscribe works.
Add a factory class for local cluster creation

Simplified single-process cluster creation by providing a factory
component.