복붙노트

[ANGULAR] rxjs와 함께 지연된 큐를 구현합니다

ANGULAR

rxjs와 함께 지연된 큐를 구현합니다

해결법


  1. 1.ConcatMap을 사용할 수 있습니다.

    ConcatMap을 사용할 수 있습니다.

    delay = 1000; // delay in ms
    queue.concatMap(e =>
        Rx.Observable.of(e) // emit first item right away
          .concat(Rx.Observable.empty().delay(delay)) // delay next item
      )
    
  2. from https://stackoverflow.com/questions/40087269/implement-delayed-queue-with-rxjs-observable by cc-by-sa and MIT license