RxJS, 비동기 함수형 프로그래밍의 매력

const nums = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]

function solution(nums: number[]):number {
	let sum:number = 0
	
	for (let i=0; i<nums.length; i++) {
		if (nums[i] <= 5) sum += nums[i]
	}
	
	return sum
}

function solution(nums: number[]):number {
	let sum: number = 0
	nums.forEach(n => sum += n)
	return sum
}

function solution(nums: number[]):number {
	return nums.reduce((prev, curr) => prev + curr, 0)
}

const points = [[1,2], [-1,5], [5,5], [3,3], [5,-7], [10,16], [6,8]]

function solution(points: number[][]):number {
	let count:number = 3
	let sum:number = 0
	
	for (let i = points.length - 1; i >= 0; i--) {
		const [X,Y] = points[i]
		if (X > 0 && Y > 0 && count > 0) {
			count--
			sum += Math.sqrt(X*X + Y*Y)
	}
	
	return sum
}

function solution(points: number[][]):number {
	
	let count = 0
	const result = points
			.filter(([X,Y]) => (X > 0 && Y > 0)) //1사분면에 있는 점을 골라
			.slice(-3) //뒤에서 3개를 잘라낸 뒤
			.map(([X,Y]) => Math.sqrt(X*X + Y*Y)) //거리를 구해서
			.reduce((prev,curr) => prev+curr, 0) //모두 더한다
						
	return result
}

...
  io.on('connection', socket => {

		//경매가 시작되면
    socket.on('start', async ({ roomId }) => {
		...
			//db에서 진행중인 경매 정보를 가져와
      const redisCli = app.get('redisCli');
      const itemId = await getRedis(redisCli, `auction:${roomId}:onLiveItem:itemId`);
      const price = await getRedis(redisCli, `auction:${roomId}:onLiveItem:startPrice`);
      //클라이언트에 전송하고 
        io.to(roomId).emit('start', { itemId: Number(itemId), price: Number(price), askingPrice: Number(price) });
      //타이머를 시작합니다.
        startCountdownTimer(app, roomId);
    });
  });
...

const events = [(connect), (enterRoom), (start), (...)]

const 경매_시작 = (roomId) => events
				.map((roomId) => getRedis(...))
				.forEach(txt => io.to(roomId).emit('start', {}))
				.then(() => startCountdownTimer(app, roomId))

const request$ = interval(1000) //1초에 한 번씩 시도하는 Observable 생성
	.pipe( 
		switchMap(() => getData()), //fetch(...) 를 통해 데이터를 가져오는 함수
		timeout(3000), //3초간 응답 없으면 에러
		catchError(err => console.error(err)), //에러 처리
		retry({count: 5, delay: (_, tries) => timer(500 * 2 ** tries)})
		//5번까지 재시도, 0.5초부터 시작해 시행횟수당 2배씩 간격 늘림
	)

const tripleTab$ = fromEvent(window, "click")
	.pipe(
	  bufferTime(300), //0.3초 동안 버퍼에 이벤트를 모읍니다
	  filter(clicks => clicks.length === 3), //클릭이 3개 모이면 TRUE
	).subscribe(event => { //do something })

export const state$ = new BehaviorSubject([])

export const setState$ = (data) => {
  const current = state$.getValue()
  state$.next([...current, ...data])
}

export function useObservable(observable) {
  const [state, setState] = useState()
  
  useEffect(() => {
    const subscription = observable.subscribe(setState)
    return () => subscription.unsubscribe()
  }, [observable])
  
  return state
}

const state = useObservable(state$)