14
14
*/
15
15
16
16
( function ( global , $ ) {
17
- var root = global . Rx ,
17
+ var root = global . Rx ,
18
18
observable = root . Observable ,
19
19
observableProto = observable . prototype ,
20
20
asyncSubject = root . AsyncSubject ,
43
43
deferred . reject ( e ) ;
44
44
} ) ;
45
45
return deferred ;
46
- } ;
47
-
46
+ } ;
47
+
48
48
$ . Callbacks . prototype . toObservable = function ( ) {
49
49
var parent = this ;
50
50
return observableCreate ( function ( observer ) {
51
51
var handler = function ( values ) {
52
- observer . onNext ( values ) ;
52
+ observer . onNext ( values ) ;
53
53
} ;
54
54
parent . add ( handler ) ;
55
55
return function ( ) {
56
- parent . remove ( handler ) ;
56
+ parent . remove ( handler ) ;
57
57
} ;
58
58
} ) ;
59
59
} ;
72
72
} ;
73
73
74
74
proto . bindAsObservable = function ( eventType , eventData ) {
75
- var parent = this ;
75
+ var parent = this ;
76
76
return observableCreate ( function ( observer ) {
77
- var handler = function ( eventObject ) {
77
+ var handler = function ( eventObject ) {
78
78
observer . onNext ( eventObject ) ;
79
79
} ;
80
80
parent . bind ( eventType , eventData , handler ) ;
84
84
} ) ;
85
85
} ;
86
86
proto . delegateAsObservable = function ( selector , eventType , eventData ) {
87
- var parent = this ;
87
+ var parent = this ;
88
88
return observableCreate ( function ( observer ) {
89
- var handler = function ( eventObject ) {
89
+ var handler = function ( eventObject ) {
90
90
observer . onNext ( eventObject ) ;
91
91
} ;
92
92
parent . delegate ( selector , eventType , eventData , handler ) ;
93
93
return function ( ) {
94
94
parent . undelegate ( selector , eventType , handler ) ;
95
95
} ;
96
96
} ) ;
97
- } ;
97
+ } ;
98
98
proto . liveAsObservable = function ( eventType , eventData ) {
99
- var parent = this ;
99
+ var parent = this ;
100
100
return observableCreate ( function ( observer ) {
101
- var handler = function ( eventObject ) {
101
+ var handler = function ( eventObject ) {
102
102
observer . onNext ( eventObject ) ;
103
103
} ;
104
104
parent . live ( eventType , eventData , handler ) ;
109
109
} ;
110
110
proto . changeAsObservable = function ( eventData ) {
111
111
return this . bindAsObservable ( 'change' , eventData ) ;
112
- } ;
112
+ } ;
113
113
proto . clickAsObservable = function ( eventData ) {
114
114
return this . bindAsObservable ( 'click' , eventData ) ;
115
115
} ;
116
116
proto . dblclickAsObservable = function ( eventData ) {
117
117
return this . bindAsObservable ( 'dblclick' , eventData ) ;
118
118
} ;
119
- proto . focusAsObservable = function ( eventData ) {
120
- return this . bindAsObservable ( 'focus' , eventData ) ;
121
- } ;
122
- proto . focusinAsObservable = function ( eventData ) {
123
- return this . bindAsObservable ( 'focusin' , eventData ) ;
124
- } ;
125
- proto . focusoutAsObservable = function ( eventData ) {
126
- return this . bindAsObservable ( 'focusout' , eventData ) ;
127
- } ;
128
- proto . keydownAsObservable = function ( eventData ) {
129
- return this . bindAsObservable ( 'keydown' , eventData ) ;
130
- } ;
131
- proto . keyupAsObservable = function ( eventData ) {
132
- return this . bindAsObservable ( 'keyup' , eventData ) ;
133
- } ;
134
- proto . loadAsObservable = function ( eventData ) {
135
- return this . bindAsObservable ( 'load' , eventData ) ;
136
- } ;
137
- proto . mousedownAsObservable = function ( eventData ) {
138
- return this . bindAsObservable ( 'mousedown' , eventData ) ;
139
- } ;
140
- proto . mouseenterAsObservable = function ( eventData ) {
141
- return this . bindAsObservable ( 'mouseenter' , eventData ) ;
142
- } ;
143
- proto . mouseleaveAsObservable = function ( eventData ) {
144
- return this . bindAsObservable ( 'mouseleave' , eventData ) ;
145
- } ;
146
- proto . mousemoveAsObservable = function ( eventData ) {
147
- return this . bindAsObservable ( 'mousemove' , eventData ) ;
148
- } ;
119
+ proto . focusAsObservable = function ( eventData ) {
120
+ return this . bindAsObservable ( 'focus' , eventData ) ;
121
+ } ;
122
+ proto . focusinAsObservable = function ( eventData ) {
123
+ return this . bindAsObservable ( 'focusin' , eventData ) ;
124
+ } ;
125
+ proto . focusoutAsObservable = function ( eventData ) {
126
+ return this . bindAsObservable ( 'focusout' , eventData ) ;
127
+ } ;
128
+ proto . keydownAsObservable = function ( eventData ) {
129
+ return this . bindAsObservable ( 'keydown' , eventData ) ;
130
+ } ;
131
+ proto . keyupAsObservable = function ( eventData ) {
132
+ return this . bindAsObservable ( 'keyup' , eventData ) ;
133
+ } ;
134
+ proto . loadAsObservable = function ( eventData ) {
135
+ return this . bindAsObservable ( 'load' , eventData ) ;
136
+ } ;
137
+ proto . mousedownAsObservable = function ( eventData ) {
138
+ return this . bindAsObservable ( 'mousedown' , eventData ) ;
139
+ } ;
140
+ proto . mouseenterAsObservable = function ( eventData ) {
141
+ return this . bindAsObservable ( 'mouseenter' , eventData ) ;
142
+ } ;
143
+ proto . mouseleaveAsObservable = function ( eventData ) {
144
+ return this . bindAsObservable ( 'mouseleave' , eventData ) ;
145
+ } ;
146
+ proto . mousemoveAsObservable = function ( eventData ) {
147
+ return this . bindAsObservable ( 'mousemove' , eventData ) ;
148
+ } ;
149
149
proto . mouseoutAsObservable = function ( eventData ) {
150
150
return this . bindAsObservable ( 'mouseout' , eventData ) ;
151
151
} ;
152
- proto . mouseoverAsObservable = function ( eventData ) {
153
- return this . bindAsObservable ( 'mouseover' , eventData ) ;
154
- } ;
155
- proto . mouseupAsObservable = function ( eventData ) {
156
- return this . bindAsObservable ( 'mouseup' , eventData ) ;
157
- } ;
158
- proto . resizeAsObservable = function ( eventData ) {
159
- return this . bindAsObservable ( 'resize' , eventData ) ;
160
- } ;
161
- proto . scrollAsObservable = function ( eventData ) {
162
- return this . bindAsObservable ( 'scroll' , eventData ) ;
163
- } ;
164
- proto . selectAsObservable = function ( eventData ) {
165
- return this . bindAsObservable ( 'select' , eventData ) ;
166
- } ;
167
- proto . submitAsObservable = function ( eventData ) {
168
- return this . bindAsObservable ( 'submit' , eventData ) ;
169
- } ;
170
- proto . unloadAsObservable = function ( eventData ) {
171
- return this . bindAsObservable ( 'unload' , eventData ) ;
172
- } ;
152
+ proto . mouseoverAsObservable = function ( eventData ) {
153
+ return this . bindAsObservable ( 'mouseover' , eventData ) ;
154
+ } ;
155
+ proto . mouseupAsObservable = function ( eventData ) {
156
+ return this . bindAsObservable ( 'mouseup' , eventData ) ;
157
+ } ;
158
+ proto . resizeAsObservable = function ( eventData ) {
159
+ return this . bindAsObservable ( 'resize' , eventData ) ;
160
+ } ;
161
+ proto . scrollAsObservable = function ( eventData ) {
162
+ return this . bindAsObservable ( 'scroll' , eventData ) ;
163
+ } ;
164
+ proto . selectAsObservable = function ( eventData ) {
165
+ return this . bindAsObservable ( 'select' , eventData ) ;
166
+ } ;
167
+ proto . submitAsObservable = function ( eventData ) {
168
+ return this . bindAsObservable ( 'submit' , eventData ) ;
169
+ } ;
170
+ proto . unloadAsObservable = function ( eventData ) {
171
+ return this . bindAsObservable ( 'unload' , eventData ) ;
172
+ } ;
173
173
proto . oneAsObservable = function ( types , selector , data ) {
174
- var parent = this ;
174
+ var parent = this ;
175
175
return observableCreateWithDisposable ( function ( observer ) {
176
- var handler = function ( eventObject ) {
177
- parent . off ( types , selector , data , handler ) ;
176
+ var handler = function ( eventObject ) {
177
+ parent . off ( types , selector , data , handler ) ;
178
178
observer . onNext ( eventObject ) ;
179
- observer . onCompleted ( ) ;
179
+ observer . onCompleted ( ) ;
180
180
} ;
181
181
parent . on ( types , selector , data , handler ) ;
182
182
return dispoableEmpty ;
183
183
} ) ;
184
184
} ;
185
185
proto . readyAsObservable = function ( ) {
186
- var parent = this ;
186
+ var parent = this ;
187
187
return observableCreateWithDisposable ( function ( observer ) {
188
- var handler = function ( eventObject ) {
188
+ var handler = function ( eventObject ) {
189
189
observer . onNext ( eventObject ) ;
190
190
} ;
191
191
parent . ready ( handler ) ;
192
192
return dispoableEmpty ;
193
193
} ) ;
194
- } ;
194
+ } ;
195
195
proto . hideAsObservable = function ( duration ) {
196
- var subject = new asyncSubject ( ) ;
196
+ var subject = new asyncSubject ( ) ;
197
197
this . hide ( duration , function ( ) {
198
198
subject . onNext ( this ) ;
199
199
subject . onCompleted ( ) ;
200
200
} ) ;
201
201
return subject ;
202
202
} ;
203
203
proto . showAsObservable = function ( duration , easing ) {
204
- var subject = new asyncSubject ( ) ;
204
+ var subject = new asyncSubject ( ) ;
205
205
this . show ( duration , function ( ) {
206
206
subject . onNext ( this ) ;
207
207
subject . onCompleted ( ) ;
208
208
} ) ;
209
209
return subject ;
210
210
} ;
211
211
proto . animateAsObservable = function ( properties , duration , easing ) {
212
- var subject = new asyncSubject ( ) ;
212
+ var subject = new asyncSubject ( ) ;
213
213
this . animate ( properties , duration , easing , function ( ) {
214
214
subject . onNext ( this ) ;
215
215
subject . onCompleted ( ) ;
216
216
} ) ;
217
217
return subject ;
218
218
} ;
219
219
proto . fadeInAsObservable = function ( duration , easing ) {
220
- var subject = new asyncSubject ( ) ;
220
+ var subject = new asyncSubject ( ) ;
221
221
this . fadeIn ( duration , easing , function ( ) {
222
222
subject . onNext ( this ) ;
223
223
subject . onCompleted ( ) ;
224
224
} ) ;
225
225
return subject ;
226
226
} ;
227
227
proto . fadeToAsObservable = function ( duration , opacity , easing ) {
228
- var subject = new asyncSubject ( ) ;
228
+ var subject = new asyncSubject ( ) ;
229
229
this . fadeTo ( duration , opacity , easing , function ( ) {
230
230
subject . onNext ( this ) ;
231
231
subject . onCompleted ( ) ;
232
232
} ) ;
233
233
return subject ;
234
234
} ;
235
235
proto . fadeOutAsObservable = function ( duration , easing ) {
236
- var subject = new asyncSubject ( ) ;
236
+ var subject = new asyncSubject ( ) ;
237
237
this . fadeOut ( duration , easing , function ( ) {
238
238
subject . onNext ( this ) ;
239
239
subject . onCompleted ( ) ;
247
247
subject . onCompleted ( ) ;
248
248
} ) ;
249
249
return subject ;
250
- } ;
250
+ } ;
251
251
proto . slideDownAsObservable = function ( duration ) {
252
- var subject = new asyncSubject ( ) ;
252
+ var subject = new asyncSubject ( ) ;
253
253
this . slideDown ( duration , function ( ) {
254
254
subject . onNext ( this ) ;
255
255
subject . onCompleted ( ) ;
256
256
} ) ;
257
257
return subject ;
258
258
} ;
259
259
proto . slideUpAsObservable = function ( duration ) {
260
- var subject = new asyncSubject ( ) ;
260
+ var subject = new asyncSubject ( ) ;
261
261
this . slideUp ( duration , function ( ) {
262
262
subject . onNext ( this ) ;
263
263
subject . onCompleted ( ) ;
264
264
} ) ;
265
265
return subject ;
266
266
} ;
267
267
proto . slideToggleAsObservable = function ( duration ) {
268
- var subject = new asyncSubject ( ) ;
268
+ var subject = new asyncSubject ( ) ;
269
269
this . slideToggle ( duration , function ( ) {
270
270
subject . onNext ( this ) ;
271
271
subject . onCompleted ( ) ;
295
295
} ;
296
296
$ . getAsObservable = function ( url , data , dataType ) {
297
297
return ajaxAsObservable ( { url : url , dataType : dataType , data : data } ) ;
298
- } ;
298
+ } ;
299
299
$ . getJSONAsObservable = function ( url , data ) {
300
300
return ajaxAsObservable ( { url : url , dataType : 'json' , data : data } ) ;
301
301
} ;
302
302
$ . getScriptAsObservable = function ( url ) {
303
303
return ajaxAsObservable ( { url : url , dataType : 'script' } ) ;
304
- } ;
305
- $ . postAsObservable = function ( url , data , dataType ) {
304
+ } ;
305
+ $ . postAsObservable = function ( url , data , dataType ) {
306
306
return ajaxAsObservable ( { url : url , dataType : dataType , data : data , type : 'POST' } ) ;
307
- } ;
307
+ } ;
308
308
} ) ( this , jQuery ) ;
0 commit comments