여기에 내가 비동기 방식으로 Zip을 사용하여 한 예를 가지고, 당신이 웹 응용 프로그램에서 호기심, 예를 들어, 우리는 서로 독립적 인 비동기 데이터 스트림의 두 세트를 얻을 필요가있을 수 있습니다. 예제에서 3개의 관측 가능은 초당 한 번 임의 정수를 방출합니다. 방출된 정수는 가장 높은 수를 방출하는 관찰 가능한 것을 결정하는 단일 관측 가능한 것으로 축소됩니다. 이 예제에서는 첫 번째 스트림의 요소 방출을 지연시키는 간격으로 스트림을 압축합니다. 이렇게 하면 rxjava 2의 zip 연산자의 결과를 결합하는 함수가 반환되는 이 예제에서는 여러 관측 가능한 항목을 단일 항목을 방출하는 관찰 가능한 항목으로 압축하는 방법을 보여 주었습니다. 이 예제에서는 결과 관찰 가능 항목이 세 개의 항목을 내보낸 후 정상적으로 완료되며, 이는 두 구성 요소 관찰(세 개의 항목을 방출하는 짝수)의 짧은 항목수로 내보내는 항목 수입니다. mergeDelayError 대신 병합을 사용하는 경우, 병합이 오류가 발생할 때 관찰 가능한 데이터 흐름을 즉시 중지하기 때문에 문자열 « rxjava »가 내보내지지 않습니다. gregwhitaker/rxjava-zip-예제에서 새로운 릴리스에 대한 알림을 원하십니까? 콜백을 구독자 메서드로 변환하여 RxJava가 간단한 개조 예제에서 작동하는 방식을 살펴보겠습니다. 예제는 다음 gradle 명령을 사용 하 여 실행할 수 있습니다. , 이러한 답변의 비 찾기 간단했다, 나는 내 자신에 의해 그것을 알아내야했다, 그래서 여기에 2 관찰에 Zip 연산자를 사용하는 간단한 예입니다 : (rxjava-조인) – 이 연산자는 현재 rxjava-contrib에서 선택적 rxjava 조인 패키지의 일부임을 나타냅니다 그리고 운영자의 표준 RxJava 세트에 포함되지 않습니다 당신은 GitHub가 코드를 호스팅하고 검토하고, 프로젝트를 관리하고, 함께 소프트웨어를 구축하기 위해 함께 일하는 3,600 만 개발자가 있는 https://github.com/politrons/reactive 여기에 더 많은 예를 볼 수 있습니다. zip에 대한 마지막 인수는 압축되는 각 관측 가능 항목의 항목을 수락하고 zip에서 반환된 관찰 가능 항목에 대한 응답으로 내보내도록 하는 함수입니다.

관찰 가능 은 2개와 9개의 개별 매개 변수 사이로 압축되도록 압축할 수 있는 관찰 가능 을 제공하거나 단일 매개 변수로 제공할 수 있습니다. 이 섹션에서는 여러 관찰 가능 을 결합하는 데 사용할 수 있는 연산에 대해 설명합니다. 이 문서에서는 관찰 가능한 것을 RxJava와 결합하는 몇 가지 방법을 보았습니다. 공식 RxJava 설명서에서 최신, 조인, 그룹조인, switchOnNext와 같은 다른 방법에 대해 알아볼 수 있습니다. . 아파치 라이센스, 버전 2.0 (« 라이센스 »)에 따라 라이센스; 이 파일은 사용권 규정을 준수하는 경우를 제외하고는 사용할 수 없습니다. 에서 라이센스 사본을 얻을 수 있습니다. . 모바일 세계에서 P.S. 스레드 를 만드는 것은 너무 많은 관찰 할 수 있으므로 현명하게 사용할 때 비용이 많이 들 수 있습니다.

. 구독으로 우리의 이전 코드를 편집읽기에 대한 각 관찰 감사에 당신이 기사를 좋아하는 경우에, 박수를 기억하십시오. 당신이 박수 버튼을 누르면, 당신은 더 많은 박수를 남길 수 있습니다! 관찰자라는 객체가 관찰 가능에서 내보내는 항목을 구독하는 관찰자 패턴을 기반으로 합니다. 따라서 출력 source2에서 source1이 모든 항목을 내보낸 후에만 항목을 내보올 수 있습니다. 즉, zip 연산자가 단일 스레드에서 작동하고 순차적으로 실행된다는 의미입니다. 관찰 가능한 시퀀스 또는 단순히 관찰 가능한 시퀀스는 비동기 데이터 스트림의 표현입니다.