RxJava AutoConnect global error handler

RxJavaAutoConnectCrash.kt

val sharedSource = Observable.just(1)
        .delay(1, TimeUnit.SECONDS)
        .map { _ ->
            // Some operation that throws an exception
            throw Exception()
        }
        .publish()
        .autoConnect(2)

val disposable = CompositeDisposable()
disposable.addAll(
        sharedSource.subscribe(
                { System.out.println("$it") },
                { it.printStackTrace() }
        ),
        sharedSource.subscribe(
                { System.out.println("$it") },
                { it.printStackTrace() }
        )
)
disposable.clear()