for wrapping listeners, i normally extent from Obs...

# rx

[myanmarking]

for wrapping listeners, i normally extent from ObservableOnSubscribe and pass it to Observable.onCreate. But i'm not sure which ones of the checks are needed. something like this