스트림에서 작동 할 때 RXJ 코드가 ​​적용되지 않는 이유는 무엇입니까?

유효하지 않은 RXJS 스트리밍 작업을위한 자주 묻는 질문 및 솔루션

RXJ를 사용하여 데이터 흐름을 처리 할 때 개발자는 종종 운영자가 예상대로 작동 할 수없는 상황을 만나게됩니다. 이 기사는 일반적인 사례를 분석하고 문제의 근본 원인을 설명하며 해결책을 제공합니다.

문제 : 두 번의 실패로 곱하기도 작동합니다

숫자 배열을 처리하고 균일 한 숫자를 필터링하고 2를 곱해야한다고 가정합니다. of , filter 및 map 연산자를 사용하여 코드는 다음과 같습니다.

 'rxjs'에서 {of} 가져 오기;
'rxjs/운영자'에서 {map, 필터} 가져 오기;

const source $ = of ([1, 2, 3, 4, 5];
소스 $ .pipe (
  필터 (항목 => 항목 % 2 === 0),
  지도 (num => num * 2)
) .subscribe (value => console.log (value));

예상 출력은 4 와 8 이지만 실제 결과에는 출력이 없습니다.

원인 분석

문제는 of 의 사용에 있습니다. of 연산자는 배열에서 각 요소를 별도로 전송하는 대신 입력 매개 변수를 전체적으로 방출합니다. 따라서 filter 및 map 연산자가 수신 한 item 배열의 단일 번호가 아닌 전체 배열 [1, 2, 3, 4, 5] 입니다. item % 2 === 0 의 판단은 전체 배열에 대해 유효하지 않아 filter 모든 컨텐츠를 필터링합니다.

해결책 : from Operator를 사용하십시오

이 문제를 해결하려면 from 대신 of 를 사용해야합니다. from 배열을 개별 요소로 나누고 관찰 가능한 요소로 하나씩 방출합니다. 수정 된 코드는 다음과 같습니다.

 'rxjs'에서 {from} 가져 오기;
'rxjs/운영자'에서 {map, 필터} 가져 오기;

const source $ = from ([1, 2, 3, 4, 5];
소스 $ .pipe (
  필터 (항목 => 항목 % 2 === 0),
  지도 (num => num * 2)
) .subscribe (value => console.log (value));

이제 filter 및 map 연산자는 최종 출력 4 및 8 사용하여 각 숫자를 올바르게 처리합니다. 이는 데이터 흐름의 올바른 처리를 위해 올바른 RXJS 연산자를 선택하는 것이 중요하다는 것을 보여줍니다.

위 내용은 스트림에서 작동 할 때 RXJ 코드가 ​​적용되지 않는 이유는 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!