android rxjava2 예제

이 연산자는 Iterable을 사용하여 항목 집합에서 관찰 가능한 항목을 만듭니다. 연산자의 예 중 일부는 에서 포함호출 가능(), fromFuture(), fromIterable(), fromPublisher(), fromArray(). 이 예제에서는 스트림에서 내보낸 첫 번째 항목을 건너뛰고 등급이 5인 해당 동영상만 필터링한 다음 각 동영상 항목의 개요를 500자로 잘립니다. 이 모든 것은 단 4줄의 코드에서만 발생합니다. 나는 하루에 하나의 예를 배우는 것이 좋습니다. 그래서 다음 날에 참조하려면이 블로그 게시물을 북마크하는 것을 잊지 마십시오. 다음은 관찰 가능한 을 만드는 예제를 보여 주며 있습니다. 우리는 안드로이드 응용 프로그램을 개발 할 때 반응 프로그래밍 원칙에 대해 들어해야합니다. RxJava 및 RxAndroid에서 시작하는 방법에 대해 작성된 여러 리소스가 있지만 한 곳에서 모든 것을 추적하는 것이 어렵다는 것을 알게되었습니다. 이 문서는 RxJava의 다양한 구성 요소의 기본 을 강조하는 동시에 Android 개발에 어떻게 적용 가능한지에 대한 몇 가지 예를 제공합니다. 반응성 프로그래밍은 데이터 흐름과 변화의 전파를 중심으로 하는 프로그래밍 패러다임입니다. 예를 들어 x = y+z를 정의한다고 가정해 보겠습니다.

y 또는 z 값을 변경하면 x 값이 자동으로 변경됩니다. y와 z의 값을 관찰하여 수행할 수 있습니다. 이것은 실제 시나리오에서 어떻게 사용할 수 있는지 를 이해하기 위한 고안된 예입니다. 나는 observeOn () 세 번 을 사용했다. 소스관찰 가능한 I/O 스레드에서 항목을 내보낸 다음 계산 스레드로 전환하여 그 직후에 지정된 잘림 작업(복잡한 계산이 요구된다고 가정해 보겠습니다). 작업이 수행되는 스레드를 변경하려면 subscribeOn 연산자를 사용하여 관찰자가 관찰 가능한 구독위치를 변경하기만 하면 됩니다. 예를 들어, 여기에 새 스레드를 만들고 이 새 스레드에서 작업을 수행하도록 지정합니다: 다음은 RxJava의 핵심 개념에 대한 심층 분석이며, 몇 가지 실제 예제와 이해하기 쉬운 코드 샘플을 통해 기초는 당신의 기억에 충실. RxJava가 무엇인지 설명하는 온라인 리소스가 이미 많이 있지만,이 기사에서 내 목표는 RxJava에 대한 기본 소개와 특히 안드로이드 개발에 어떻게 맞는지 제공하는 것입니다. 또한 새 프로젝트 나 기존 프로젝트에 통합 할 수있는 방법에 대한 몇 가지 구체적인 예제와 제안을 제공합니다.

예를 들어, 여기에서는 모든 관찰자에게 단일 문자열을 내처리하는 관찰 가능 을 만듭니다: Observable.subscribe() 구독(흐름 가능) 또는 일회용 개체를 반환합니다. 가능한 (임시) 메모리 누수를 방지하려면 onStop()` 활동 또는 조각의 메서드에서 관찰 가능한 구독을 취소합니다.