rx-java2

0열

1답변

내가이 매우 간단한 RxJava 예,이 결과를 제공 List<Integer> arrayIntegers = new ArrayList<>(Arrays.asList(1, 2, 3, 4, 5)); Observable.fromIterable(arrayIntegers).map(i -> { Log.d("RxJava", "map i = " + i);

0열

1답변

UI 스레드에서 findallAsync(). asFlowable()을 실행 한 연산자가

문제가 발생했습니다. rxjava 연산자가 UI 스레드에서 실행되고 있습니다. findAllAsync()를 사용하여 객체를 비동기 적으로 가져오고 asFlowable()을 사용하여 rxjava 연산자로 객체를 처리합니다. realm.where(Specie.class) .equalTo("fauna", true) .findAllAsyn

1열

3답변

rxjava2 - 어쩌면 다른 사람이

rxjava2에서 flowable이 조건부 행동으로 이어지는 경우를 처리하기 위해 권장되는 방법을 찾고 있습니다. 그렇지 나는 새로운 String을 만들고 데이터베이스에 저장하려면 존재 않을 경우 보다 구체적으로, 나는 String이있는 경우 Maybe<String>가있는 나는 데이터베이스에 String를 업데이트 할 사항이 있거나. 나는 아래 생각하지만

0열

1답변

N 요청이 완료 될 때까지 X 요청을 병렬로 실행합니다.

주어진 사용 사례에 적절한 구조를 찾는 데 문제가 있습니다. 주어진 입력 문자열에 대해 Single<String>을 생성하는 기능이 있습니다. 이 Single은 최대 30 분이 소요될 것으로 예상되는 여러 작업의 조합이지만이 질문과 관련이 없다고 생각합니다. 내가 달성하고자하는 동작은 5 개의 작업을 N 개의 작업을 완료하는 목표와 동시에 활성화하는 것입니

0열

1답변

RxJava를 사용하여 여러 구독자 및 데이터 흐름을위한 전략 2

RxJava2을 사용하여 올바르게이 작업을 구현하는 방법을 결정할 수 없습니다. 문제는 다음과 같습니다. AuidoRecord을 사용하여 오디오를 녹음합니다. 당신은 내가 수동으로 목록에 가입자를 추가하고 볼 수 있듯이 현재 그 private class StreamAudioRecordRunnable extends Flowable<short[]> implem

1열

1답변

추가 요청이 실패했을 때 갱신 요청 본문을 얻는 방법은 무엇입니까?

RxJava를 개장 한 상태에서 사용하고 있습니다. 나는 그것이 실패하거나 성공했을 때 요청에 의해 보내진 BODY/RAW를 어떻게 찾을 수 있는지 알고 싶다. 이것은 API 호출 내 컨트롤러 : ChatMessage body = new ChatMessage(); ... //configuration of body variable is om

0열

1답변

rxjava2 in android에서 에러 처리하는 방법

안녕하세요, 안드로이드 앱에 LiveData과 RxJava2을 사용하고 있습니다. 다음을 사용하여 http 전화를 걸고 있습니다. @Inject lateinit var retrofit: Retrofit override fun doServerLoginApiCall(email: String, password: String): LiveData<LoginRe

0열

1답변

방 - LiveData RxJava가 이유없이 트리거 됨

Activity, ViewModel, Singleton 저장소 및 Room이 있습니다. activitiy의 OnCreate에서 나는 뷰 모델을 만들 : viewModel = ViewModelProviders.of(this).get(MainViewModel::class.java) viewModel.myData.observe(this, Observer { d

1열

2답변

RxJava와 Realm을 사용하여 로컬 데이터 소스를 구성하는 방법은 무엇입니까?

저는 Realm이 asFlowable 기능을 소개하는 RxJava 2를 지원하므로 매우 기쁩니다. 내가 직면 한 문제는 내 로컬 데이터 소스 싱글 톤 클래스에서 영역 인스턴스의 수명주기를 가장 잘 관리하는 방법입니다. 내 로컬 데이터 소스는 Android 구조 샘플 here과 유사합니다. RxJava의 렐름 예제에서는 onCreate에서 영역 인스턴스를 인

0열

1답변

반응 의존적 EditText

3 개의 편집 텍스트가 서로 종속되어 있습니다. 설명해 드리겠습니다 : 사용자가 edittext1에 값을 입력하면 edittext2 및 edittext3의 값이 계산됩니다. edittext2 및 edittext3에서도 마찬가지입니다. 즉, 한 가지 유형의 데이터를 가진 사용자는 다른 두 가지 유형의 데이터를 계산할 수 있습니다. 그러나 완벽하지는 않습니다.