android - Bagaimana untuk mengawal susunan rxjava multi-thread concurrency

Question

Keperluan adalah untuk mendapatkan senarai sembang daripada pelayan, dan kemudian melintasi untuk mendapatkan rekod sembang saya menggunakan Observable.from(perbualan) di sini dan kemudian memasukkan perbualan ke dalam pangkalan data tempatan, ditapis untuk mendapatkan data yang diperlukan, dan akhirnya. mengemas kini paparan
Saya menontonnya sepanjang petang, jadi Berkaitan dengan berbilang kata kunci
SerializedSubject (saya tidak boleh menggunakan SerializedSubject.from(conversations), dan ralat dilaporkan semasa menukar kepada Observable)
trampolin (letakkan tugas dalam baris gilir benang semasa, tunggu sehingga tugas semasa selesai, dan kemudian teruskan melaksanakan baris gilir) Tugas)
concatEager (Apakah perbezaan antara operator ini dan concatMap http://blog.csdn.net/kisty_ya... Tetapi ada tiada contoh penggunaan dan saya tidak faham)
Pada mulanya, langkah seterusnya diproses dalam onNext, dan kemudian saya menggunakan flatMap untuk mengendalikannya, tetapi ia tamat apabila pelancaran selesai, saya tidak menunggu onNext untuk menyelesaikan pelaksanaan, dan saya merasakan bahawa doOnNext dan flatMap adalah sama. Saya harap anda boleh memberi saya nasihat. Bolehkah anda menuliskan idea itu dalam kod palsu

Answer 1

Jika anda ingin menapis, anda harus menggunakan operator Penapis

Answer 2

Menggunakan operator concatMap ini boleh memastikan bahawa susunan pelaksanaan benang tidak akan bercelaru!

Answer 3

    Obserable.fromCallable()
             .filter()
             .subscribe(io)
             .obserableOn(ui)
             .subscribe(action)
             
如果是需要将过滤的数据重新保存
    Obserable data = Obserable.fromCallable()
             .filter()
             .subscribe(io)
             .share();
   data.obserableon(io)
       .subscribe(数据库)
   data.obserableOn(ui)
       .subscribe(更新)