요구 사항은 서버에서 채팅 목록을 가져온 다음 여기에서 Observable.from(conversations)을 사용한 다음 대화를 로컬 데이터베이스에 삽입하고 필터링하여 필요한 데이터를 가져오는 것입니다. update view
오후 내내 봤는데 여러 키워드 관련
SerializedSubject (SerializedSubject.from(conversations)를 사용할 수 없고 Observable로 변환하면 오류가 발생합니다.)
trampoline (작업을 큐에 넣습니다) 현재 스레드에서 현재 작업이 완료될 때까지 기다린 다음 대기열을 계속 실행합니다.) Task)
concatEager(이 연산자와 concatMap의 차이점은 무엇입니까 http://blog.csdn.net/kisty_ya... 그런데 거기에 사용예도 없고 이해가 안가네요)
처음에는 onNext에서 다음 단계를 처리하다가 flatMap을 이용해서 처리했는데, 런칭이 완료되자마자 기다리지 않고 종료됐어요. 실행을 마치는데 doOnNext와 flatMap이 같은 것 같아요. 조언 좀 해주실 수 있으면 좋겠습니다. 의사 코드로 아이디어를 적어주실 수 있나요?
필터링을 하려면 필터 연산자를 사용해야 합니다
이 연산자 concatMap을 사용하면 스레드 실행 순서가 무질서해지는 것을 방지할 수 있습니다!
으아아아