seoft

Accept personal information handling terms 1. Purpose of processing personal information ('seoft.tistory.com' or'SEOFT') processes personal information for the following purposes, and is not used for purposes other than . ​ 2. Rights, obligations and methods of exercising the information subject As a personal information subject, the user can exercise the following rights. ① The information subj..

concatMapEager는 기존 concatMap 역할에서 스트림이 병렬로 처리된다는 특징을 가지고 있다. 그렇기 때문에 동시성과 함께 순서가 보장되어야 될 경우 concatMapEager 연산자를 사용하면 된다. 여러 api host로부터 값을 받오는 즉시 처리하되, 순서를 보장해야되는게 요구사항이라고 가정을 해본다. request함수를 사전 정의 하였는데 각 url에 따른 randome 시간 후에 response가 오는 상황으로 가정하고 해당 함수를 거쳐 Single로 반환된다. url string 리스트를 개별 flowable로 반환하여 concatMapEager내에서 하나씩 태우게 되고 반환된 Single 결과값을 flowable으로 변환에 스트림을 진행한다. string리스트의 순서와 동일하게..

zip 연산자를 통해 Observable을 동시에 실행하고 결과값을 받아 처리할 수 있다. 이때 FunctionN 은 ~9 까지 지원하는데 만약 Observable이 컴파일단에 정해지지 않고 동적으로 할당되거나 갯수가 10개가 넘는 경우에는 위와 같은 방법으로 어려울 수 있고 다음과 같은 방법으로 사용할 수 있다. Observable(single) 자체로 구성된 리스트를 zip에 넣고, zip 내에서는 array로 받아 사용할 수 있다. 만약 Any타입으로 zip 내에서 사용되기 때문에 타입변환 등 타입에 대해 민감 할 경우 future를 사용하는 방법도 있다. 기존의 single 리스트를 toFuture시키면서 일괄 진행시키고, 합쳐야 될 상황에 get으로 비동기가 완료되고 반환된 값을 받아 처리할 수..