🛠️ 처음부터 만드는 Observable — RxJS-style 지연 스트림 파이프라인 20줄 구현

RxJS는 18,000+ GitHub 스타의 리액티브 프로그래밍 라이브러리다.
핵심은 단순하다: "구독 전까지 아무것도 실행하지 않는 게으른 스트림".

핵심 구현 (20줄)

```typescript
type Observer = { next: (v: T) => void };
class Observable {
constructor(private _sub: (obs: Observer) => void) {}
subscribe(next: (v: T) => void) { this._sub({ next }); }
pipe(...ops: ((s: Observable) => Observable)[]) {
return ops.reduce((s, op) => op(s), this as Observable);
}
}
const map = (fn: (v: T) => R) => (src: Observable) =>
new Observable(o => src.subscribe(v => o.next(fn(v))));
const filter = (fn: (v: T) => boolean) => (src: Observable) =>
new Observable(o => src.subscribe(v => fn(v) && o.next(v)));
const take = (n: number) => (src: Observable) =>
new Observable(o => {
let i = 0;
src.subscribe(v => i++ < n && o.next(v));
});
const from = (arr: T[]) =>
new Observable(o => arr.forEach(v => o.next(v)));
```

사용법

```typescript
from([1, 2, 3, 4, 5])
.pipe(
filter(n => n % 2 === 1), // 홀수만
map(n => n * 10), // 10배
take(2) // 2개만
)
.subscribe(v => console.log(v));
// 10, 30
```

핵심 패턴: Lazy Evaluation

`.pipe()`는 파이프라인을 설계만 한다. 실제 데이터는 `.subscribe()` 시점에 흐른다.
각 operator는 새 Observable을 반환하는 고차 함수다. `subscribe()` 호출 시 체인을 역방향으로 소스까지 타고 올라간 뒤, 데이터가 순방향으로 흘러내린다.
Promise가 "미래의 단일 값"이라면, Observable은 "미래의 여러 값 스트림"이다.