Remove stampit in favour of a factory function
This commit is contained in:
@@ -1,6 +1,5 @@
|
||||
import { Observable, Disposable } from 'rx';
|
||||
import Fetchr from 'fetchr';
|
||||
import stampit from 'stampit';
|
||||
|
||||
function callbackObserver(observer) {
|
||||
return (err, res) => {
|
||||
@@ -13,36 +12,33 @@ function callbackObserver(observer) {
|
||||
};
|
||||
}
|
||||
|
||||
|
||||
export default stampit({
|
||||
init({ args: [ options ] }) {
|
||||
this.services = new Fetchr(options);
|
||||
},
|
||||
methods: {
|
||||
readService$({ service: resource, params, config }) {
|
||||
return Observable.create(observer => {
|
||||
this.services.read(
|
||||
resource,
|
||||
params,
|
||||
config,
|
||||
callbackObserver(observer)
|
||||
);
|
||||
|
||||
return Disposable.create(() => observer.dispose());
|
||||
});
|
||||
},
|
||||
createService$({ service: resource, params, body, config }) {
|
||||
return Observable.create(observer => {
|
||||
this.services.create(
|
||||
resource,
|
||||
params,
|
||||
body,
|
||||
config,
|
||||
callbackObserver(observer)
|
||||
);
|
||||
|
||||
return Disposable.create(() => observer.dispose());
|
||||
});
|
||||
}
|
||||
export default function servicesCreator(options) {
|
||||
const services = new Fetchr(options);
|
||||
function readService$({ service: resource, params, config }) {
|
||||
return Observable.create(observer => {
|
||||
services.read(
|
||||
resource,
|
||||
params,
|
||||
config,
|
||||
callbackObserver(observer)
|
||||
);
|
||||
return Disposable.create(() => observer.dispose());
|
||||
});
|
||||
}
|
||||
});
|
||||
function createService$({ service: resource, params, body, config }) {
|
||||
return Observable.create(observer => {
|
||||
services.create(
|
||||
resource,
|
||||
params,
|
||||
body,
|
||||
config,
|
||||
callbackObserver(observer)
|
||||
);
|
||||
return Disposable.create(() => observer.dispose());
|
||||
});
|
||||
}
|
||||
return {
|
||||
readService$,
|
||||
createService$
|
||||
};
|
||||
}
|
||||
|
Reference in New Issue
Block a user