Implement Rx Observer.Create