Hi there. How would you wrap async methods in Rx? I use

BillingClient

, that has a connection callback, then I make some query with some results that I also receive in some other callback. How would I deliver these results to an Observable?