android - 拡張関数が新しい Observable オブジェクトを作成しない

Question

kotlin と rxjava で予期しない動作が発生しています。picasso を使用して画像を読み込むための拡張関数を作成します

fun Picasso.loadBitmap(url: String) : Observable<Bitmap>
        = Observable.create<Bitmap> {
    emitter ->
    Log.d("picasso load bitmap", "me ${this}")
    try {
        val bitmap = load(url).centerCrop()
                .resize(100, 100)
                .transform(CircleTransformer())
                .get()
        emitter.onNext(bitmap)
        emitter.onComplete()
    } catch (e: IOException) {
        emitter.onError(e)
    }
}

このように近い間隔で（ほぼ同時に）これを複数回呼び出すと、

picasso.loadBitmap(place.image_url)
    .subscribeOn(Schedulers.io())
    .retryWhen { error ->
        error.zipWith(Observable.range(1, 5),
                BiFunction<Throwable, Int, RetryWrapper> {
                    t1, t2 -> RetryWrapper(t2.toLong(), t1) })
                .flatMap {
                    if(it.delay < 4){
                        Log.d(TAG, "retry no. ${it.delay} for ${place.image_url}")
                        Observable.timer(it.delay * 5, TimeUnit.SECONDS)
                    } else {
                        Log.d(TAG, "DMD ${place.image_url}")
                        Observable.error { it.error }
                    }
                }

    }
    .subscribe (
        { bitmap ->
            markers.find { it.place.id == place.id }?.let {
                it.marker.icon = IconFactory.getInstance(context).fromBitmap(bitmap)
            }
        },
        {
            Log.e(TAG, "error decoding ${place.image_url}", it)
        })

が呼び出されるたびにloadBitmap、新しいオブザーバブルが作成されることを期待しています。しかし、私はこれをログに記録しました

09-28 11:17:00.022 31694-32276/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.068 31694-32277/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.069 31694-31959/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.108 31694-32278/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.112 31694-32251/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.125 31694-32260/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.162 31694-31794/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.192 31694-32280/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.195 31694-32279/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:00.219 31694-32281/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:04.828 31694-32262/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:14.885 31694-31793/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26
09-28 11:17:29.928 31694-32269/? D/picasso load bitmap: me com.squareup.picasso.Picasso@c894e26

オブザーバブルはすべてのloadBitmap呼び出しで同じです。retryWhen失敗すると、次の失敗に進まないため、独自のオブザーバブルが必要です。それが理にかなっていることを願っています。

deferオブザーバブルをorの中に入れてflatmapも何も変わりません。

コードを編集

override fun render(state: MainState) {
        map?.let { map ->
            val newMarkers: MutableList<PlaceMarker> = mutableListOf()
            for(place in state.places) {
                var placeMarker = placeMarkers.find { it.place.id == place.id }
                if(placeMarker != null && map.markers.contains(placeMarker.marker)) {
                    newMarkers.add(placeMarker)
                    placeMarkers.remove(placeMarker)
                } else {
                    if(placeMarker != null) placeMarkers.remove(placeMarker)
                    val option = MarkerOptions()
                    option.position = LatLng(place.latitude, place.longitude)
                    option.snippet = place.name
                    placeMarker = PlaceMarker(place, map.addMarker(option))
                    newMarkers.add(placeMarker)

                    picasso.loadBitmap(place.image_url)
                            .subscribeOn(Schedulers.io())
                            .retryWhen { error ->
                                error.zipWith(Observable.range(1, 5),
                                        BiFunction<Throwable, Int, RetryWrapper> {
                                            t1, t2 -> RetryWrapper(t2.toLong(), t1) })
                                        .flatMap {
                                            if(it.delay < 4){
                                                Log.d(TAG, "retry no. ${it.delay} for ${place.image_url}")
                                                Observable.timer(it.delay * 5, TimeUnit.SECONDS)
                                            } else {
                                                Log.d(TAG, "DMD ${place.image_url}")
                                                Observable.error { it.error }
                                            }
                                        }
                            }
                            .subscribe (
                                    { bitmap ->
                                        placeMarkers.find { it.place.id == place.id }?.let {
                                            it.marker.icon = IconFactory.getInstance(context).fromBitmap(bitmap)
                                            bitmap.recycle()
                                        }
                                    },
                                    {
                                        Log.e(TAG, "error decoding ${place.image_url}", it)
                                    })
                }

            }
            placeMarkers.forEach { it.marker.remove() }
            placeMarkers.clear()
            placeMarkers.addAll(newMarkers)
        }
    }

私は MVP を使用していますが、少し広く見えるようにしています。したがって、これはVIEW内の関数であり、MODELがサーバーからデータを取得し終わった後にレンダリングがトリガーされます。