rx emit

var observable = Rx.Observable.create(function (observer) {
    var source = new Source
    while (source.hasNext())
        observer.onNext(source.getNext());
});



/*************  without having to close over source ************/

var observable = Rx.Observable.create();
var source = new Source
while (source.hasNext())
     observable.emitNext(source.getNext())