막내의 막무가내 프로그래밍 & 일상

[2020.12.30 블로그 포스팅 스터디 다섯 번째 글] [스케줄러] : 쉽게 설명하면 어떤 프로그램의 세부 일정(스케줄)을 주관하는 관리자로 생각하면 됩니다. 즉 스케줄러는 스레드를 지정할 수 있게 해주며 단순히 새로운 스레드를 생성해주고 어려운 비동기 흐름 관리를 쉽게 사용할 수 있도록 지원해주는 역할을 합니다. RxJava를 보통 네트워크 통신에 처음 사용해보는 경우가 많습니다. 저 또한 그랬고요. 그리고 자연스럽게 subscribeOn() 과 observeOn() 도 접하게 됩니다. 이 두 함수도 스케줄러를 지정하는 함수인데요. subscribeOn() 함수는 구독자가 Observable에 subscribe() 함수를 호출하여 구독할 때 실행되는 스레드를 지정합니다. observeOn() 함수는..

[2021-04-16 업데이트] [2020.12.12 블로그 포스팅 스터디 2 번째 글] [변환 연산자] : 변환 연산자는 만들어진 데이터 흐름을 원하는 대로 변형할 수 있습니다. 대표적인 예로 map()과 flatMap()이 있는데 둘의 차이점은 Observable하게 만드냐 안만드냐 차이가 있습니다. 이번 포스팅에서는 flatMap()과 같은 계열인 함수들에 대해 살펴보려고 합니다. [+] flayMap()은 map()함수를 좀 더 발전시킨 함수로 map() 함수는 원하는 입력값을 어떤 함수에 넣어서 변환할 수 있는 일대일 함수이고 flatMap() 함수는 똑같이 함수에 넣더라도 결과가 Observable로 나온다는 차이점이 있습니다. 또한 flatMap()은 일대다 혹은 일대일 Observable함..

[2021-04.16 업데이트] [2020.12.01 블로그 포스팅 스터디 첫 번째 글] RxJava 의 연산자에 대해 나중에 쉽게 찾고 활용할 수 있도록 간단한 설명과 함께 포스팅을 해보려고 합니다. ㅎㅎ [생성 연산자] : 생성 연산자의 역할은 Observable, Single 등과 같은 데이터 흐름을 만드는 것 입니다. (just(), fromArray(), fromIterable, onNext(), onError(), onComplete() 등이 있는데 이건 제외해서 남기겠습니다.) 1. interval() -> 일정 시간 간격으로 데이터 흐름을 생성합니다. 기본적인 스케줄러는 SchedulerSupport.COMPUTATION으로 계산 스케줄러에서 실행 됩니다. 함수 파라미터로는 (long pe..

[2021-04-16 업데이트] 안녕하세요ㅎㅎ RxJava 책을 복습과 함께 틈틈히 정리하면 더 기억에 남을 것 같아 포스팅을 하게되었습니다. RxJava의 Observable 에는 Cold, Hot 두 종류의 Obsevable이 있습니다. 둘의 큰 차이점은 Cold는 구독하기 전까지 데이터를 방출하지 않는 Lazy한 접근법이고 Hot은 구독자의 존재 여부 관계없이 데이터블 발행하는 Observable입니다. (그래서 데이터를 발행하는 속도와 구독자가 처리하는 속도가 크면 원치않는 문제가 생기기 때문에 배압에 주의해야합니다.) Cold 를 사용하는 예시는 웹 요청, 데이터베이스 쿼리, 파일 읽기가 있습니다. Hot 을 사용하는 예시는 마우스 이벤트, 키보드 이벤트, 시스템 이벤트, 센서 데이터 등이 있습..

class BachelorNoticeRemoteDataSourceImpl : BachelorNoticeRemoteDataSource { override fun requestNotice(): Single { return Single.fromObservable( Observable.create { val bachNoticeList: ArrayList = ArrayList() val doc: Document = Jsoup.connect("https://computer.cnu.ac.kr/computer/notice/bachelor.do") .get() // Base Url val contentElements: Elements = doc.select("div[class=b-title-box]").select("a..