Transforme várias solicitações de ajax em Observables com o RxJS
Estou lutando com algo - o que acho que significa que eu entendi mal e estou fazendo algo bobo
Eu tenho um observável e preciso usá-lo para criar algum objeto, enviá-lo ao servidor para processamento, combinar um resultado do servidor com o objeto que enviei e depois transformá-lo em um observável, para o que eu quero fazer (acho que ) é algo como
var theNewObservable = my.observable.things.select(function(thing) {
var dataToSend = generateMyJavascriptObjectFrom(thing);
var promise = $.ajax({
type: 'POST',
url: http://somewhere.com,
data: dataToSend
}).promise();
return rx.Observable.fromPromise(promise).subscribe(function(data, status, jqXHR) {
var infoFromServer = jqXHR.getResponseHeader('custom-header-returned');
// I'm wanting this to be the thing other code can subscribe to
return { infoFromServer: dataToSend };
}, function(err) {
alert('PC LOAD LETTER!');
console.error(err);
});
}
});
theNewObservable.subscribe(function(combinedInfo) { console.log(combinedInfo) };
onde eu estou esperando{infoFromServer: dataToSend}
Estou recebendo umAutoDetachObserver
e eu posso ver que tem um onNext com a assinatura ajax onSuccess, então eu obviamente estou fazendo algo bobo