You don't need to create this object, that's what AtomicObservableSubscription.wrap already does. It checks for null and only invokes if it received a subscription (meaning it executed asynchronously).