올해는 머신러닝이다.

앞에서 본 예제처럼 connect() 를 통해 동시 실행할 수 있다.하지만 자동으로 connect를 할수도 있다.주의 할 내용은 자동 연결(Auto connection) 은 사용할 때 상당한 주의를 요한다. 뜻하지 않게 배출시 제대로 되지 않는 경우가 발생될 수 있기 때문이다.그럼 예제를 살펴보자 .이전장에서 했던 2가지 서로 다른 배출 방법에 자동 연결만 추가한 부분이다.Observable threeRandoms = Observable.range(1,3) .map(i->randomInt()) .publish() .autoConnect(2); //2번에 대해서 자동 연결을 하겠다는 뜻이다.!! //Observable 1 배출 threeRandoms.subscribe( i->System.out.printl..

기본적인 Observable 생성 후 배출은 다음과 같습니다.Observable threeIntegers = Observable.range(1 , 3); threeIntegers.subscribe( i -> System.out.println("Observer 1 : " + i)); threeIntegers.subscribe( i -> System.out.println("Observer 2 : " + i)); -------------------------- Observer 1 : 1 Observer 1 : 2 Observer 1 : 3 Observer 2 : 1 Observer 2 : 2 Observer 2 : 3 보다시피 Observable 1 이 끝나고Observable 2가 다시 실행되는 구조로 되어..

일반적으로 Observable들은 cold상태인것들이다.RxJava를 하다보면 많이 듣는 게 cold와 hot Observable이다.도대체 이것들이 뭔가..Cold Observable일반적인 옵저버형태를 말한다.누가 구독해주지 않으면 데이터를 배출을 하지 않는다.일반적인 웹 요청 , 데이터베이스 쿼리등이 사용되며 내가 요청하면 결과를 받는 과정을 거친다.처음부터 발행하는 걸 기본으로 한다.Hot Observable구독자의 존재 여부와 상관없이 데이터를 배출하는 Observable 이다.그래서 여러 구독자에 선택적으로 고려가능하다.구독시점으로부터 발행하는 값을 받는 걸 기본으로 한다.마우스 이벤트 , 키보드 이벤트 , 시스템 이벤트등이 주로 사용된다.멀티캐스팅도 포함된다.데이터 발행자와 수신자도 이참에 ..