Hi, is there a way for a custom observable created via Observable.create() to emit on scheduler specified via subscribeOn if wrapped async api changes thread of callback? (Other than observseOn...) I.e. I have bluetooth android API I am wrapping, and it automatically emits its callbacks on main thread, and id like to keep the subscribeOn scheduler

If you’re trying to wrap Android bluetooth, you might take a look at https://github.com/Polidea/RxAndroidBle and see if that has what you need.