С помощью этого кода в виду:Observable.prototype.concatAll, кажется, не дают ожидаемого результата
const Rx = require('rxjs');
var i = 3;
const obs = Rx.Observable.interval(10)
.map(() => i++)
.map(function(val){
return Rx.Observable.create(obs => {
obs.next(val)
});
})
.take(10)
.concatAll();
obs.subscribe(function(v){
console.log(v);
});
Я бы ожидал, что результат вошли быть что-то вроде:
[3,4,5,6,7,8,9,10,11,12]
То есть, 10 значений, начиная с 3
Однако, все мы получаем только
3
Кто-нибудь знает, почему это было бы?
большое спасибо - я бы подумал 100%, что взять (10) устранило бы необходимость для полного вызова(), который вы говорите, необходимо. Не имеет смысла, что вам нужно вызвать complete(). (10) должны позаботиться об этом. Извините, но RxJS не делает правильные вещи в этом случае IMO. –
В качестве очень простого примера. Марк: –
const obs = Rx.Observable.interval (10) .toArray(); –