Превратите несколько запросов AJAX в Observables с RxJS
Я борюсь с чем-то - что, я думаю, означает, что я неправильно понял и делаю что-то глупое
У меня есть наблюдаемое, и мне нужно использовать его для создания какого-либо объекта, отправить его на сервер для обработки, объединить результат с сервера с отправленным объектом, а затем превратить его в наблюдаемое, чтобы я хотел сделать (я думаю, ) это что-то вроде
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) };
где я ожидаю{infoFromServer: dataToSend}
Я получаюAutoDetachObserver
и я вижу, что имеет onNext с подписью ajax onSuccess, поэтому я, очевидно, делаю что-то глупое