Mengapa kod RXJS saya tidak berkuatkuasa semasa beroperasi di sungai?

Soalan dan penyelesaian yang sering ditanya untuk operasi streaming RXJS yang tidak sah

Apabila menggunakan RXJS untuk memproses aliran data, pemaju sering menghadapi situasi di mana pengendali tidak dapat berfungsi seperti yang diharapkan. Artikel ini akan menganalisis kes biasa, menerangkan punca utama masalah dan memberikan penyelesaian.

Masalah: Operasi walaupun mendarabkan oleh dua gagal

Katakan kita perlu memproses pelbagai nombor, menapis nombor dan membiaknya dengan 2. Kod menggunakan of , filter dan pengendali map adalah seperti berikut:

 import {of} dari 'rxjs';
import {peta, penapis} dari 'rxjs/operator';

const source $ = of ([1, 2, 3, 4, 5]);
sumber $ .pipe (
  penapis (item => item % 2 === 0),
  peta (num => num * 2)
) .subscribe (value => console.log (nilai));

Output yang dijangkakan adalah 4 dan 8 , tetapi hasil sebenar tidak mempunyai output.

Menyebabkan analisis

Masalahnya terletak pada penggunaan of . of memancarkan parameter input secara keseluruhan, bukannya menghantar setiap elemen dalam array secara berasingan. Oleh itu, item yang diterima oleh filter dan pengendali map adalah keseluruhan array [1, 2, 3, 4, 5] , bukannya satu nombor dalam array. Penghakiman item % 2 === 0 tidak sah untuk keseluruhan array, menyebabkan filter menyaring semua kandungan.

Penyelesaian: Gunakan pengendali from

Untuk menyelesaikan masalah ini, from pengendali harus digunakan dan bukannya of . Operator from operator memisahkan array ke dalam elemen individu dan memancarkannya ke dalam satu demi satu. Kod yang diubahsuai adalah seperti berikut:

 import {dari} dari 'rxjs';
import {peta, penapis} dari 'rxjs/operator';

const source $ = dari ([1, 2, 3, 4, 5]);
sumber $ .pipe (
  penapis (item => item % 2 === 0),
  peta (num => num * 2)
) .subscribe (value => console.log (nilai));

Sekarang pengendali filter dan map akan mengendalikan setiap nombor dengan betul, dengan output akhir 4 dan 8 . Ini menunjukkan pentingnya memilih pengendali RXJS yang betul untuk pemprosesan aliran data yang betul.

Atas ialah kandungan terperinci Mengapa kod RXJS saya tidak berkuatkuasa semasa beroperasi di sungai?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!