Eugen Martynov
private fun notifyEmitterWithException(emitter: MaybeEmitter<*>, e: Exception) { if (!emitter.isDisposed) { emitter.onError(e) } }