reactive-programming

-1열

1답변

저는 RxJava를 처음 사용하고 있으며 종종 아래 조건부 연산과 같은 솔루션을 사용하고 있습니다. 여기에 두 개의 호출을 차례로 연결 한 다음 호출 체인의 결과가 무엇인지에 따라 int를 반환하려고합니다. 이 코드를 향상시키는 "rxified"방법이 있습니까? @ andrei-에 의해 제안으로 받아 들여 확인하기 위해 논리를 이동 한 후 return re

2열

1답변

순차적이고 조건부로 반응적인 프로그래밍을 수행하는 방법은 무엇입니까?

순차적 및 조건부로 둘 이상의 작업을 실행하려고합니다. 작업이 순차적으로 실행되어야합니다. 다음 예제는 이미이를 수행 할 수 있습니다. 하지만 그렇게 할 수는 없습니다. 첫 번째 작업의 결과에 따라 두 번째 작업이 작동해야하는지 여부를 결정하려고합니다. 첫 번째 연산의 결과에 따라 두 번째 연산에 매개 변수를 전달하려고합니다. 코드가 구독 이벤트 범위에 쓰

0열

1답변

rxjs 내가 관찰 가능한 rxjs에서 switchMap에 대한 혼란이의 OnError 행동

을 switchMap. 그래서 어떤 오류에 대한 새 구독을 만들지 않기 위해 그것을 처리하는 방법이 있습니까? 나는 오류를 포착하여 Observable을 반환하려고 시도했지만 구독은 중단되었습니다. upd : 가져 오는 대신 각도 2 http.get을 처리하는 방법은 무엇입니까?

0열

1답변

수신 자바 내가 간단한 클래스가 그룹과 디 바운스

별도의 각 그룹에 무한 스트림을 분할 : public class Event { String objectId; } 그리고 어떤 이벤트 소스를 나의 관찰에 이벤트를 방출. 이 소스는 무한하며 동일한 objectId로 이벤트를 몇 번 보낼 수 있습니다. 따라서 값을 objectId으로 그룹화 한 다음 각 그룹을 디버깅하려고합니다. 의 내가 E1-E

0열

1답변

RxJava flat map : 결과 관찰 점 중 하나가 완료되면 어떻게됩니까?

저는 RxJava를 처음 사용했습니다. 플랫 맵은 방출 된 항목을 관찰 가능하게 매핑하는 것입니다. 또한, documentation에 기반하여 방출 된 관측 값은 모두 단일 관측 가능 스트림으로 결합 (병합)된다는 것을 알고 있습니다. 내면 관측 대상 중 일부가 완료되면 어떻게되는지 궁금합니다. 예 : 항목 데이터 키를내는 관찰 가능 항목이 있습니다. 서버

2열

2답변

RxJava. 관측 가능 파일 읽기

저는 RxJava와 반응 형 프로그래밍이 완전히 새롭습니다. 파일을 읽고 Observable에 저장해야하는 과제가 있습니다. 나는 내부에 BufferedReader를 사용하여 Callable을 만들고 Observable.fromCallable()을 사용하려고 시도했지만 많이 작동하지 않았습니다. 내가 어떻게 할 수 있습니까? RxJava 2.0을 사용하고

1열

2답변

RxJS 메소드가 정적이 아닌 이유는 무엇입니까?

RxJS withLatestFrom은 인스턴스 메소드입니다. Observable의 인스턴스는 메소드를 호출하기 위해 새로 생성/생성되어야합니다. merge 메서드는 정적 메서드입니다. 인스턴스가 필요하지 않습니다. 왜 RxJS withLatestFrom은 정적 방법이 아닌 인스턴스 방법입니까?

2열

1답변

CombineLatest를 사용하여 여러 그룹에 대해 세 개의 이벤트 스트림을 서로 연관시킵니다.

날짜 순서대로 세 가지 관찰 가능한 이벤트 스트림 (주요 이벤트, 고객에 대한 이벤트 및 고객 관련 이벤트)이 있습니다. 각 스트림은 다양한 이벤트 차량마다 각 이벤트마다 vehicleID와 다양한 기타 속성이 있습니다. 한 차량과 다른 차량에 대해 이벤트가 표시 될 수 있으므로 기본적으로 VehicleID를 기반으로 3 개의 독립적 인 이벤트 스트림을 서

1열

1답변

종단 간 반응 형 스트리밍 RESTful 서비스

this post을 읽었으며 어리석은 질문인지 잘 모릅니다. 나는 반응 프로그래밍의 완전히 초보자이다. 질문은 매우 간단합니다. 완전히 반응이 좋은 백엔드가 있다고 가정하면 브라우저에서 스트리밍 (예 : 큰 텍스트) 할 수 있고 서버에서 오는 즉시 각 청크를 사용자에게 어떻게 인쇄 할 수 있습니까? ? 아마 몇 가지 중요한 개념적 포인트가 누락되었지만 알아

1열

1답변

Android RxJava 병렬 처리 - ExecutorService를 사용한 컴퓨팅

RxJava로 작은 Java 프로그램을 성공적으로 완료했습니다. 코드는 다음과 같습니다. public static void main(String[] args) { int threadCt = Runtime.getRuntime().availableProcessors() + 1; //multi-threading ExecutorSe