1
- 'use strict' ;
2
- let { Rx} = require ( '@cycle/core' ) ;
3
- let jsonp = require ( 'jsonp' ) ;
1
+ let { Rx} = require ( `@cycle/core` )
2
+ let jsonp = require ( `jsonp` )
4
3
5
4
function createResponse$ ( url ) {
6
5
return Rx . Observable . create ( observer => {
7
- if ( typeof url !== ' string' ) {
8
- observer . onError ( new Error ( ' Observable of requests given to JSONP ' +
9
- ' Driver must emit URL strings.' ) ) ;
10
- return ( ) => { } ; // noop
6
+ if ( typeof url !== ` string` ) {
7
+ observer . onError ( new Error ( ` Observable of requests given to JSONP ` +
8
+ ` Driver must emit URL strings.` ) )
9
+ return ( ) => { } // noop
11
10
}
12
11
13
12
try {
14
13
jsonp ( url , ( err , res ) => {
15
14
if ( err ) {
16
- observer . onError ( err ) ;
15
+ observer . onError ( err )
17
16
} else {
18
- observer . onNext ( res ) ;
19
- observer . onCompleted ( ) ;
17
+ observer . onNext ( res )
18
+ observer . onCompleted ( )
20
19
}
21
- } ) ;
20
+ } )
22
21
} catch ( err ) {
23
- observer . onError ( err ) ;
22
+ observer . onError ( err )
24
23
}
25
- } ) ;
24
+ } )
26
25
}
27
26
28
27
function makeJSONPDriver ( ) {
29
28
return function jsonpDriver ( request$ ) {
30
29
return request$ . map ( url => {
31
- let response$ = createResponse$ ( url ) ;
32
- response$ . request = url ;
33
- return response$ ;
34
- } ) ;
35
- } ;
30
+ let response$ = createResponse$ ( url )
31
+ response$ . request = url
32
+ return response$
33
+ } )
34
+ }
36
35
}
37
36
38
37
module . exports = {
@@ -56,5 +55,5 @@ module.exports = {
56
55
* @return {Function } the JSONP Driver function
57
56
* @function makeJSONPDriver
58
57
*/
59
- makeJSONPDriver
60
- } ;
58
+ makeJSONPDriver,
59
+ }
0 commit comments