Convert async to rxjava