complete all netflix samples

rebcabin · rebcabin · commit f509bb0aed9c · 2013-04-14T16:36:59.000-07:00
diff --git a/rxjava/expt1/src/expt1/core.clj b/rxjava/expt1/src/expt1/core.clj
@@ -1,10 +1,14 @@
 (ns expt1.core
-  (:require [expt1.k2 :as k2])
+  (:require [expt1.k2 :as k2]
+;           [expt1.k1 :as k1]
+            )
   (:import [rx Observable Observer Subscription]
            [rx.util AtomicObservableSubscription])
   (:gen-class)
   )
 
+
+
 (defn -main
   "I don't do a whole lot ... yet."
   [& args]
@@ -20,4 +24,27 @@
    (Observable/filter (fn [x] (= 0 (mod x 2))))
    (.subscribe println))
 
+  (.subscribe (k2/customObservableBlocking) println)
+
+  (.subscribe (k2/customObservableNonBlocking) println)
+
+  (->
+   (k2/fetchWikipediaArticleAsynchronously ["Tiger" "Elephant"])
+   (.subscribe #(println "--- Article ---\n" (subs (:body %) 0 125) "..."))
+   )
+
+  (k2/simpleComposition)
+
+  (->
+   (k2/getVideoForUser 12345 78965)
+   (.subscribe
+    (fn [datum] (println "--- Object ---\n" datum))
+    (fn [exception] (println "--- Error ---\n" exception))
+    (fn [] (println "--- Completed ---\n"))))
+
+  (->
+   (k2/fetchWikipediaArticleAsynchronouslyWithErrorHandling ["Tiger" "NonExistentTitle" "Elephant"])
+   (.subscribe #(println "--- Article ---\n" (subs (:body %) 0 125) "...")
+               #(println "--- Error ---\n" (.getMessage %))
+               ))
   )
diff --git a/rxjava/expt1/src/expt1/k1.clj b/rxjava/expt1/src/expt1/k1.clj
@@ -1,4 +1,4 @@
-(ns expt1.k1.core ;;rx-clj.core
+(ns expt1.k1 ;;rx-clj.core
   (:refer-clojure :exclude [concat cons drop drop-while empty
                             filter first future
                             interpose into keep keep-indexed last
@@ -83,6 +83,8 @@
   (.unsubscribe s)
   s)
 
+;;; bbeckman this would not load
+
 (defn ^Subscription subscription
   "Create a new subscription that calls the given no-arg handler function"
   [handler]
diff --git a/rxjava/expt1/src/expt1/k3.clj b/rxjava/expt1/src/expt1/k3.clj
