Implement Rx subject example