| 1 | const request = require('request');
|
| 2 | const { Observable } = require('rxjs');
|
| 3 |
|
| 4 | exports.request = (options) => {
|
| 5 | return Observable.create(observer => {
|
| 6 | // const options = {
|
| 7 | // url: `${baseURL}${url}`,
|
| 8 | // method,
|
| 9 | // headers,
|
| 10 | // json: data,
|
| 11 | // timeout
|
| 12 | // };
|
| 13 | console.log(options.url);
|
| 14 | request(options, (err, res, body) => {
|
| 15 | if(err) observer.error(err)
|
| 16 | else observer.next(body);
|
| 17 | }).on('close', () => {
|
| 18 | observer.complete();
|
| 19 | });
|
| 20 | });
|
| 21 | } |
| \ | No newline at end of file |