2015-12-22 19:32:12 -08:00
|
|
|
import stamp from 'stampit';
|
2015-12-29 17:35:50 -08:00
|
|
|
import { post$, postJSON$ } from '../utils/ajax-stream.js';
|
2015-12-26 00:42:39 -08:00
|
|
|
|
2015-12-22 19:32:12 -08:00
|
|
|
const serviceStamp = stamp({
|
|
|
|
methods: {
|
|
|
|
readService$(resource, params, config) {
|
2015-07-25 15:15:59 -07:00
|
|
|
|
2015-12-22 19:32:12 -08:00
|
|
|
return Observable.create(function(observer) {
|
|
|
|
services.read(resource, params, config, (err, res) => {
|
|
|
|
if (err) {
|
2016-01-04 14:26:07 -08:00
|
|
|
return observer.onError(err);
|
2015-12-22 19:32:12 -08:00
|
|
|
}
|
2015-07-25 15:15:59 -07:00
|
|
|
|
2015-12-22 19:32:12 -08:00
|
|
|
observer.onNext(res);
|
|
|
|
observer.onCompleted();
|
|
|
|
});
|
|
|
|
|
|
|
|
return Disposable.create(function() {
|
2016-01-04 14:26:07 -08:00
|
|
|
observer.dispose();
|
|
|
|
});
|
|
|
|
});
|
|
|
|
},
|
|
|
|
createService$(resource, params, body, config) {
|
|
|
|
return Observable.create(function(observer) {
|
|
|
|
services.create(resource, params, body, config, (err, res) => {
|
|
|
|
if (err) {
|
|
|
|
return observer.onError(err);
|
|
|
|
}
|
|
|
|
|
|
|
|
observer.onNext(res);
|
2015-12-22 19:32:12 -08:00
|
|
|
observer.onCompleted();
|
|
|
|
});
|
2016-01-04 14:26:07 -08:00
|
|
|
|
|
|
|
return Disposable.create(function() {
|
|
|
|
observer.dispose();
|
|
|
|
});
|
2015-12-22 19:32:12 -08:00
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
2015-07-13 00:25:01 -07:00
|
|
|
});
|