Estoy usando RxJS aquí y parece que no puedo superar estoaparentemente Problema simple.

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');
    });

El código anterior escupe cada elemento de la matriz en orden como se esperaba.

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);
    });
}

Aquí, aunque solo obtengo la matriz completa (es decir,[ 1, 2, 3, 54, 3, 22, 323, 23, 11, 2 ]) ¿No debería RxJS estar separando el resultado? Espero que al menos tenga algo de lógica para esto.

Gracias