리액티브 프로그래밍은 데이터 플로우나 상태를 변화시킬때의 비동기적인 처리를

외부에서 계속 들어오는 데이터를 가지고 처리를 하는 것이다.(오직 밖에서 안으로) 이 외부에서 들어오는 데이터는 이벤트, ajax처리, 프로그래머의 입력 등이 있다.

프로그램을 짜는 방식에는 두가지 방식이 있다. 프로그램에서 외부 환경을 기다리는 pull 방식과, 기다리게 리스닝 시켜놓고 그외 일을 처리하는 push방식

pull 방식에는 c언어의 scanf()함수나, 네트워크 프로그래밍에서의 listen함수가 대표적이라고 생각 하고 이해를 시작하자. pull방식으로 외부에서 데이터를 받을 경우 그 프로그램은 해당 부분에서 멈추는 bolcking 행동을 한다.

push방식에는 주로 이벤트 리스너들이 이야기가 되고 그 리스너에 맞는 이벤트가 들어오면 내부 함수를 실행시킨다.

pull방식에는 대표적으로 iterator방식을 예로 들 수 있다.

Vector arr = new Vector<>(); arr.add("gd"); arr.add("gd"); arr.add("gd"); Iterator it = arr.iterator();

while(it.hasMoreNext()){ String str = it.next(); System.out.println( "그 값은 : "+ str); }

데이터를 while문 내에서 외부에있는 it의 데이터를 달라고 쪼른다

push방식에는 observer패턴이 있다.

const observable = Rx.Observable.of(["ㅎㅇ","ㅎㅇ","ㅎㅇ"]) observable.pipe({ map(el => "그 값은 : " + el) })

observable.subscribe({ next : (v) => console.log(v), })

위 두코드의 차이는 데이터를 요청 하는 위치에서 차이가 난다. iterator 형식으로 데이터를 요청을 할 때에는, 그 데이터를 while이라는 실제 로직을 행하는 내부에서 데이터를 외부에 요청을 보내서 받아오는 방식이다. 반면 observable로 실행을 할 경우, 데이터를 외부에서 흘러 내려보내고 그 받았을때의 실행할 함수를 정의를 하는 방식인데, 마치 외부에서 데이터가 로직 내부로 들어올 때, 그 내부에서 실행되는 로직을 정의 해주는 방식이다.

LinQ (Language INtergrated Query) => C# 3.0부터 등장한 언어로 C#에 코드에 SQL문과 비슷한 언어를 집어넣어서 배열이나 데이터 처리를 좀 더 수월 하게 끔 사용 할 수 있게끔 하는 것이다 (결국 데이터를 핸들링하는데에는 SQL만한 것이 없다라는 다른 뒷 받침이되네)

C#에서의 LinQ 코드 샘플 //query syntax : 쿼리 방식으로 짜기 IEnumerable numQuery1 = from num in numbers where num % 2 ==0 orderby num select num;

(numbers에서 짝수인 숫자를 num 을 기준으로 오름차순해서 numQuery1에 집어넣어버리기)

Method syntax : 함수 방식으로 짜기 (ORM이 이걸 보고 바탕으로 나오지 않았을까??)
그리고 rx는 바로 이 메소드 방식의 LinQ방식을 참조해서 만들었다고 생각해도 될 정도로 깊은 관계를 가지고 있음

IEnumerable<int> numQuery2 =  numbers
	.Where(num => num%2 ==0)
	.OrderBy(n => n);

// drag의 이벤트 들을 마치 쿼리문 던지듯이 받아와서 그 데이터를 처리한다고 생각을 해보자 const drag = Rx.Observable.fromEvent(window, 'mouseup'); drag.pipe({ flatMap(ev =>({ startX : ev.pageX, startY : ev.pageY })) }) drag.subscribe((pos)=>{ console.log(pos); })

첫줄에서는 drag 변수에 이벤트로 받아오는 리스트들 즉 배열을 저장한다고 생각을 하자. 2번째 줄에서는 그 받아온 배열을 가지고 어떻게 행동을 할 것인지 생각을 하는데 , flatMap이라는 함수를 통해서 이벤트에 대한 pageX와 pageY를 value값으로 startX, startY라는 키값에 각각 넣고, 그 해당 객체를 리턴한다.

마지막 subscribe는 그 받아온 객체를 가지고 어떤 행동을 할 것인지에 대해 정의를 하면 마우스 이벤트에 따른 행동을 하게된다.