rx-java

1열

1답변

복잡한 문제를 해결하기 위해 반응 형 프로그래밍 (RxJava)을 사용해야합니까?

나는 RxJava Observable로서 이벤트 스트림을 표현하기 시작한 어플리케이션을 가지고있다. 이벤트의 요구 사항과 구조는 처음에는 간단 했으므로 RxJava와 함께 제공된 운영자는 필요한 단순 변환에 매우 적합했습니다. 그러나 그 이후로 요구 사항과 비즈니스 논리는 훨씬 더 복잡해졌습니다. 매우 특별한 방법으로 사건을 연관시킬 필요성이 생겼고 Obs

0열

2답변

수 초가 걸릴 때까지 Rx 건너 뛰기

X 초마다 신호를 계속 내보내는 PublishSubject가 있습니다. Y 초 후에 방출되는 첫 번째 항목 만 고려하고 싶습니다. 예 관찰 A는 매초 관찰 B 만 사이에 것들을 무시이 "체크"5 초마다 출사한다 "체크"방출한다. 즉, 일정한 시간이 경과 할 때까지 모든 항목을 건너 뜁니다. 이 원인은 바운스가 발광하지 않고 5초 을 요지 관찰 가능한 원래

0열

1답변

RxJava 2 : Observable.create() 비동기 코드가 Thread.sleep()을 사용하여 종료 될 때까지 대기

Observable.create(...)을 사용하여 일부 비동기 코드를 래핑합니다. 비동기 코드는 5 초 동안 "활성"상태 여야하며 중지해야합니다. Observable.<MyObject>create(emitter -> { // Some async code emitter.setDisposable(Disposables.fromRunnabl

0열

2답변

RxJava를 사용하는 항목의 필터 목록

RxJava로 항목 목록을 필터링하는 방법은 무엇입니까? 나는 다음과 같은 코드를 가지고 loadData()는 List<Chatroom> 방출 : repository.loadData() .subscribe(chatrooms -> { view.showData(chatrooms); view.showEmptyState(chat

0열

2답변

RxJava/RxScala에서 observable 캐시하는 방법

RxScala를 기반으로하는 반응성 스칼라 드라이버를 사용하여 mongodb를 호출하는 REST API가 있습니다. 내 API 컨트롤러 또는 서비스 계층에서 , 내가 어떻게 할 수 hazelcast (또는 다른 캐싱 도구) 내 모든 서비스가 비동기입니다 만 관찰 반환, 어떤 생각을 사용하여 MongoDB를 호출을 피하기 위해 캐싱을 사용할 필요가 관찰 할

1열

2답변

프로파일 러를 사용하여 메모리 누수를 찾을 수있는 방법

이미 메모리를 덤프하고 메모리 누수가 있는지를 확인했습니다. 스크린 샷을 보면 한 조각 만 있지만 같은 유형의 발표자가 9 명 있다는 것을 알 수 있습니다. 오직 하나만 있어야합니다. 발표자 인스턴스 중 하나를 검사하면 프로파일 러에서 발표자에 대한 참조를 표시합니다. 이것들은 모두 RxAndroid 메소드의 콜백 메소드입니다. 조각의 onDestroyVi

-1열

1답변

개조 + RxJava 내가 쿼리에 필요한 API를 사용하고 다른 링크

으로 다시 시도 특정 국가의 출시 연도 만 있으므로 1 년 동안 +/- 요청을 다시 시도해야 할 수도 있습니다. 다른 말로하면 첫 번째 시도가 실패하면 다른 링크/쿼리로 다시 시도하고 싶습니다. Retrofit 및 RxJava를 사용하여 어떻게이 작업을 수행 할 수 있습니까?

2열

2답변

RxJava : 타임 스탬프가 만료 될 때까지 캐시에서 읽음

다음과 같은 시나리오가 있습니다. Foo이라는 개체에 내 응용 프로그램이 관심이 있습니다.이 Foo 개체는 원격 서비스에서 가져오고이 인스턴스를 로컬로 캐시하고 싶습니다. 일정 시간이 경과 할 때까지 계속 사용하십시오. 지금까지 내가 왔어요 이제 public class FooState { private Foo foo; private lo

0열

2답변

RxJava 디 바운스 메서드 호출이 수신되었습니다.

메서드 호출을위한 간단한 스로틀을 만들고 싶습니다. 내가 doSomething(number)에 대한 호출받은 그 수와 debounce에 기초한 관찰을 만들려면, public void called(int number){ doSomething(number); } 가이 방법은 너무 자주 호출됩니다 나는이 방법을 가지고있다. 이것이 가능합니까? 이

1열

1답변

배열 목록에있는 모든 관찰 가능한 문자열 수집

키/값 쌍이 포함 된 map이 있습니다. 이 map에서 결과로 반환하는 데이터베이스에 스트리밍하여 저장합니다. Observable<String>. 차단하지 않고이 문자열에 도달하려고 시도하면 문제가 발생합니다. 항상 비어 있습니다. 여기에 제 구현입니다 : public Observable<List<String>> uploadKeys(Map<String, S