Implement Rx AsyncSubject example