Fix webtoon viewer pages not loading

Partial revert of fddca15182

app/src/main/java/eu/kanade/tachiyomi/ui/reader/viewer/webtoon/WebtoonPageHolder.kt

@@ -246,28 +246,30 @@ class WebtoonPageHolder(
         unsubscribeReadImageHeader()
         val streamFn = page?.stream ?: return
 
+        var openStream: InputStream? = null
         readImageHeaderSubscription = Observable
             .fromCallable {
                 val stream = streamFn().buffered(16)
-                val imageStream = process(stream)
+                openStream = process(stream)
-                val isAnimated = ImageUtil.isAnimatedAndSupported(stream)
+
-                Pair(imageStream, isAnimated)
+                ImageUtil.isAnimatedAndSupported(stream)
             }
             .subscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
-            .doOnNext { (imageStream, isAnimated) ->
+            .doOnNext { isAnimated ->
-                imageStream.use {
+                frame.setImage(
-                    frame.setImage(
+                    openStream!!,
-                        it,
+                    isAnimated,
-                        isAnimated,
+                    ReaderPageImageView.Config(
-                        ReaderPageImageView.Config(
+                        zoomDuration = viewer.config.doubleTapAnimDuration,
-                            zoomDuration = viewer.config.doubleTapAnimDuration,
+                        minimumScaleType = SubsamplingScaleImageView.SCALE_TYPE_FIT_WIDTH,
-                            minimumScaleType = SubsamplingScaleImageView.SCALE_TYPE_FIT_WIDTH,
+                        cropBorders = viewer.config.imageCropBorders,
-                            cropBorders = viewer.config.imageCropBorders,
+                    ),
-                        ),
+                )
-                    )
-                }
             }
+            // Keep the Rx stream alive to close the input stream only when unsubscribed
+            .flatMap { Observable.never<Unit>() }
+            .doOnUnsubscribe { openStream?.close() }
             .subscribe({}, {})
 
         addSubscription(readImageHeaderSubscription)