Наблюдаемого что задерживает случайное время каждый раз, когда поток заканчивается

Question

мне нужно создать бот, который твиты со случайными интервалами, как это:

wait 1 hour 
tweets something 
wait 5 hours 
tweets something 
wait 30 minutes 
tweets something 
wait 10 hours 
tweets something 

, где время задержки между 10 часов или что-то вроде этого

Проблема с наблюдаемыми заключается в том, что мне нужно сгенерировать эти интервалы, а затем подавать их в цепочку наблюдаемых. Например, мне нужно создать массив со всеми задержками, и только они подписываются на него, чтобы чирикать.

Нет ли способа создать наблюдаемое, которое испускает новый элемент, только когда он закончится? Например:

Rx.Observable.just().timer(randomTime()).subscribe(emitObservableAgain()); 

Я думаю, что это как-то не то, что предназначены Наблюдатели. Как ... это хорошая оценка, чтобы связать конец цепочки наблюдаемых с самим собой?

ТАКЖЕ, как импортировать rx.timer в nodejs? Импорт только «гх» (от НПМ) не даст мне этим функциям

Answer 1

Вы можете использовать повтор:

Rx.Observable.just() 
    .switchMap(() => Rx.Observable.timer(randomTime())) 
    .do(tweetMyThing) 
    .repeat() 
    .subscribe(); 

Edit: Я добавил жить-скрипт, который показывает, как работает поток:

// Helper-Methods to visualize the stream 
 
function randomTime() { 
 
    return ~~(Math.random() * 2000) + 50; 
 
} 
 

 
var lastReceivedEvent = +new Date(); 
 
function tweetMyThing(value) { 
 
    console.log("Received after " + (+new Date() - lastReceivedEvent)); 
 
    lastReceivedEvent = +new Date(); 
 
} 
 
// \end of helper-methods 
 

 
// the stream 
 
Rx.Observable.just() 
 
    .switchMap(() => Rx.Observable.timer(randomTime())) 
 
    .do(tweetMyThing) 
 
    .repeat(20) 
 
    .subscribe();

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.1.0/rx.all.js"></script>