File tree Expand file tree Collapse file tree 3 files changed +47
-2
lines changed
language-adaptors/rxjava-clojure/src/examples/clojure/rx/lang/clojure/examples Expand file tree Collapse file tree 3 files changed +47
-2
lines changed Original file line number Diff line number Diff line change
1
+ ;
2
+ ; Copyright 2013 Netflix, Inc.
3
+ ;
4
+ ; Licensed under the Apache License, Version 2.0 (the "License");
5
+ ; you may not use this file except in compliance with the License.
6
+ ; You may obtain a copy of the License at
7
+ ;
8
+ ; http://www.apache.org/licenses/LICENSE-2.0
9
+ ;
10
+ ; Unless required by applicable law or agreed to in writing, software
11
+ ; distributed under the License is distributed on an "AS IS" BASIS,
12
+ ; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ ; See the License for the specific language governing permissions and
14
+ ; limitations under the License.
15
+ ;
1
16
(ns rx.lang.clojure.examples.http-examples
2
17
(:require [rx.lang.clojure.interop :as rx]
3
18
[clj-http.client :as http])
Original file line number Diff line number Diff line change
1
+ ;
2
+ ; Copyright 2013 Netflix, Inc.
3
+ ;
4
+ ; Licensed under the Apache License, Version 2.0 (the "License");
5
+ ; you may not use this file except in compliance with the License.
6
+ ; You may obtain a copy of the License at
7
+ ;
8
+ ; http://www.apache.org/licenses/LICENSE-2.0
9
+ ;
10
+ ; Unless required by applicable law or agreed to in writing, software
11
+ ; distributed under the License is distributed on an "AS IS" BASIS,
12
+ ; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ ; See the License for the specific language governing permissions and
14
+ ; limitations under the License.
15
+ ;
1
16
(ns rx.lang.clojure.examples.rx-examples
2
17
(:require [rx.lang.clojure.interop :as rx])
3
18
(:import rx.Observable rx.subscriptions.Subscriptions))
Original file line number Diff line number Diff line change
1
+ ;
2
+ ; Copyright 2013 Netflix, Inc.
3
+ ;
4
+ ; Licensed under the Apache License, Version 2.0 (the "License");
5
+ ; you may not use this file except in compliance with the License.
6
+ ; You may obtain a copy of the License at
7
+ ;
8
+ ; http://www.apache.org/licenses/LICENSE-2.0
9
+ ;
10
+ ; Unless required by applicable law or agreed to in writing, software
11
+ ; distributed under the License is distributed on an "AS IS" BASIS,
12
+ ; WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ ; See the License for the specific language governing permissions and
14
+ ; limitations under the License.
15
+ ;
1
16
(ns rx.lang.clojure.examples.video-example
2
17
(:require [rx.lang.clojure.interop :as rx])
3
18
(:import [rx Observable Observer Subscription]
128
143
(.onCompleted observer)
129
144
(Subscriptions/empty ))))
130
145
131
- (comment (.subscribe (video-list->videos (video-list 2)) println))
146
+ (comment (.subscribe (video-list->videos (video-list 2 )) ( rx/action* println) ))
132
147
133
148
(defn ^Observable video->metadata
134
149
[video-id]
163
178
:actual-star-rating (rand-int 5 ) })
164
179
(.onCompleted observer))))
165
180
166
- (comment (.subscribe (video->rating 234345 8888) println))
181
+ (comment (.subscribe (video->rating 234345 8888 ) ( rx/action* println) ))
167
182
You can’t perform that action at this time.
0 commit comments