you never call `observer.onSubscribe` and `onCompl...

# rx

[jw]

you never call observer.onSubscribe and onComplete still runs after an exception is thrown