Я пытаюсь реализовать версиюэто вступление к RxJS (возиться здесьчто вместо того, чтобы выбирать случайный объект из возвращенного массива API, он потребляет задний поток объектов из возвращенного массива API.

Вот часть кода, который производит контролируемыйObservable из ответа API (полная скрипкаВот):

var responseStream = requestStream.flatMap(function (requestUrl) {
    return Rx.Observable.fromPromise(fetch(requestUrl));
}).flatMap(function(response) {
    return Rx.Observable.fromPromise(response.json());
}).flatMap(function(json) {
    return Rx.Observable.from(json);
}).controlled();

Я просто сбрасываю каждого испущенного пользователя вconsole.logи использоватьclick поток событий для запускаrequest() позвонить в контролируемую Observable:

responseStream.subscribe(function(user) {
  console.log(user);
});

refreshClickStream.subscribe(function (res) {
    responseStream.request(1);
});

Из API GitHub возвращено около 50 пользовательских объектов, и я хотел бы задним ходом потреблять их по одному за клик (как показано выше).тем не мениепосле того, как я только что вышел из пользовательских объектов, я хотел бы отправить еще один вызовrequestStream чтобы получить еще один вызов API, пополнитеresponseStream и продолжить предоставление пользовательских объектовconsole.log на каждый клик. Каков будет RxJS-дружественный способ сделать это?