RxJS: Bir dizi sonucu bölme Observable.fromPromise

Question

Ben burada RxJS kullanıyorum ve bu görünen basit bir sorun üzerinde görünmüyor gibi görünmüyor.

rx.Observable 
    .from([1,2,3,54,3,22,323,23,11,2]) 
    .distinct() 
    .subscribe(function next (x) { 
     console.log('Next'); 
     console.log(x); 
    }, function error (x) { 
     console.log('Error'); 
     console.log(x); 
    }, function completed() { 
     console.log('Completed'); 
    }); 

Yukarıdaki kod, her dizi öğesini beklendiği gibi tükürür. Sadece tam bir dizi elde de aşağıda

rx.Observable 
    .fromPromise(getNumbers([1,2,3,54,3,22,323,23,11,2])) 
    .distinct() 
    .subscribe(function next (x) { 
     console.log('Next'); 
     console.log(x); 
    }, function error (x) { 
     console.log('Error'); 
     console.log(x); 
    }, function completed() { 
     console.log('Completed'); 
    }); 

function getNumbers (nums) { 
    return new Promise(function (resolve, reject) { 
     resolve(nums); 
    }); 
} 

(yani [ 1, 2, 3, 54, 3, 22, 323, 23, 11, 2 ]). RxJS sonucu bozmayacak mı? En azından bunun için bir mantığı olduğunu umardım.

Eğer

Answer 1

Hayır o ayrı örtük onları kırmak olmaz ederiz. Onları dizi dümdüz hangi flatMap kullanmak bölmek isterseniz: Alternatif

rx.Observable 
    .fromPromise(getNumbers([1,2,3,54,3,22,323,23,11,2])) 
    .flatMap(function(x) { return x; }) 
    .distinct() 
    .subscribe(function next (x) { 
     console.log('Next'); 
     console.log(x); 
    }, function error (x) { 
     console.log('Error'); 
     console.log(x); 
    }, function completed() { 
     console.log('Completed'); 
    });