Получение элементов в onNext () после вызова dispose () в RxJava

Question

Получение элементов в onNext () после вызова dispose () в RxJava

Попробуйте следующее:

{% extends intro == 'false' 
    ? 'UdoWebsiteBundle::layout.html.twig' 
    : 'UdoWebsiteBundle::layout_true.html.twig' %}

Идея взята здесь: http://jorisdewit.ca/2011/08/27/extending-different-layouts-for-ajax-requests -в-прут-Symfony2 /

0

kotlin observable rx-java2 dispose

задан Maksim Dmitriev 25 February 2019 в 00:16

1 ответ

Другие вопросы по тегам:

kotlin observable rx-java2 dispose

Похожие вопросы:

score 0 · Answer 1

Вы распорядились работником, который предоставлял предметы, а не подписчиком.

Чтобы прекратить получать предметы, попробуйте

val compositeDisposable = CompositeDisposable()
    compositeDisposable.add(
            Observable
                    .create { e: ObservableEmitter<String> ->
                        val worker = Schedulers.io().createWorker()
                        e.setDisposable(worker)
                        worker.schedule {
                            for (i in 1..5) {
                                if (i == 3) {
                                    compositeDisposable.dispose() //changed here
                                }
                                e.onNext("Event $i on thread ${Thread.currentThread().name}")
                            }
                        }

                    }
                    .subscribe(
                            { s ->
                                Log.d(TAG, "createObservableWithDisposable onNext msg=$s")
                            },
                            { e ->
                                Log.d(TAG, "createObservableWithDisposable", e)
                            },
                            {
                                Log.d(TAG, "createObservableWithDisposable onComplete")
                            }

                    )
    )