얄코의 반응형 프로그래밍 - 자바스크립트로 쉽게 배우는 ReactiveX대시보드

7:40초부터, subscribe를 사용했을 때 처럼, 이 혹시 subject를 사용했을 때 처럼을 의미하신걸까요 ?

npm install rxjs 이후에 , node src/test1 으로 실행하면 아래와 같이 에러가 나는데 package.json 을 수정해야하나요?    Error: Cannot find module 'D:\src\test1'     at Function.Module._resolveFilename (internal/modules/cjs/loader.js:880:15)     at Function.Module._load (internal/modules/cjs/loader.js:725:27)     at Function.executeUserEntryPoint [as runMain] (internal/modules/run_main.js:72:12)     at internal/main/run_main_module.js:17:47 {   code: 'MODULE_NOT_FOUND',   requireStack: [] }  

안녕하세요! 또 궁금한게 생겨서 질문을 올립니다!   http request로 pagination되어 있는 데이터를 모두 가져오려고 하는데요!   우선 1~100페이지정도 까지 계속 데이터를 수집하다가 어느순간에 결과가 빈배열로 응답이 오면    요청을 멈추도록 구현하고 싶습니다.   ex)URI/1    ->  [a,b,c]   -> 10초 걸림 URI/2    ->  [d,e,f]  -> 8초 걸림 URI/3   -> []   -> 1초걸림   이런상황에 3번째에서 멈춘뒤 [a,b,c,d,e,f] 의 결과를 얻고 싶습니다.   현재는range(1,100).pipe(concatMap((number) => http.get(`URL/${number}`))takewhile((value)=> value.length)reduce((acc,cur) => acc.concat(cur), [])이런식으로 빈배열이 응답오면 멈추는 식으로 구현되어 있습니다!이걸 mergeMap으로 동시성을 조금 올려보고 싶은데,mergeMap으로 하니 각 요청마다 응답에 걸리는 시간이 다른 이유 때문에(추측), 데이터가 담겨잇는 응답은 늦게 오고 데이터가 담겨 있지 않은 빈배열은 응답이 먼저 도착해서  takewhile 조건에걸려서 종료되어 버리는 문제가 발생하고 있습니다. pagination으로 가져온 데이터의 순서는 중요하지 않아서 종료조건만 해결하면 될것같은데, 종료조건때문에 순서를 정렬할수있는 방법을 고려해야하나 싶은데요   이런 문제를 해결하고 싶은데제가 생각한대로 mergeMap의 순서를 정렬하는 방법을 강구해보는게 맞을까요?   더 쉽게 해결할 수 있는 방법이 있을까 해서 질문 올립니다!

초당 2회 요청할 수 있는 API가 있는데   mergeMap에서 concurrent를 2로 설정하는 방식으로 해보았는데 이래도 429 too may request 에러가 나오더라구요   그래서 지금은 concatMap을 사용해서 처리하고 있는데,   rxjs가 익숙치 않다보니 초당 2회로 제한하는 아이디어가 잘 떠오르지 않습니다.   이런상황도 rxjs로 처리할 수 있는지 궁금해요!

안녕하세요. pluck Operator 강의를 듣는 중에  올려주신 코드를 복사해서 실행하였으나, 실행이 되지않아 문의 드립니다.   js console http://api.github.com/search/users?q=user:mojombo  

  node src/main 을 실행하면 아래와같은 메시지가 표출됩니다  

제가 rxjs에대해서 정확히 개념이 안잡힌거 같은데요, rxjs 는 반응형 프로그램이라는건 이해했는데, 그럼 제이쿼리 같은 프레임워크인건가요? 호스팅 서버에서 rxjs를 이용하려면 <script src="https://unpkg.com/@reactivex/rxjs/dist/global/rxjs.umd.js"></script> 만 사용해서 이용하면 되는건가요?   그리고 rxjs 사용시 node.js 서버를 설치했는데, 그러면 rxjs는 node.js의 일종인가요?

https://rxjs.dev/api/index/function/defer 위 공식문서에 따르면 아래와 같이 설명되어있습니다. Creates the Observable lazily, that is, only when it is subscribed. defer allows you to create an Observable only when the Observer subscribes. 공식문서 예제에서의 팩토리 함수는 조건에 따라 옵저버블을 생성하는 것이지만 팩토리 함수가 꼭 조건에 따라 다른 옵저버블을 생성할 필요는 없는 것 같아요. 그저 레이지하게(옵저버가 옵저버블을 구독할 때) 옵저버블을 만들어 내는 함수로 이해됩니다.