Merge pull request #74 from minamimonji/change_project_name

Change the project name and the module name from Rx.rb to RxRuby
ReactiveX · Dec 17, 2015 · 8befc0b · 8befc0b
2 parents e493b32 + e64ef4b
commit 8befc0b
Show file tree

Hide file tree

Showing 178 changed files with 675 additions and 676 deletions.
diff --git a/Gemfile b/Gemfile
@@ -1,4 +1,4 @@
 source 'https://rubygems.org'
 
-# Specify your gem's dependencies in Rx.rb.gemspec
+# Specify your gem's dependencies in rx_ruby.gemspec
 gemspec
diff --git a/examples/aggregate.rb b/examples/aggregate.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
 # Using a seed for the accumulate
-source = RX::Observable.range(1, 10).aggregate(1) {|acc, x|
+source = RxRuby::Observable.range(1, 10).aggregate(1) {|acc, x|
     acc * x
 }
 
@@ -20,7 +20,7 @@
 # => Completed
 
 # Without a seed
-source = RX::Observable.range(1, 10).aggregate {|acc, x|
+source = RxRuby::Observable.range(1, 10).aggregate {|acc, x|
     acc + x
 }
 

diff --git a/examples/amb.rb b/examples/amb.rb
@@ -1,9 +1,9 @@
-require 'rx'
+require 'rx_ruby'
 
 # Using Observable sequences
-source = RX::Observable.amb(
-    RX::Observable.timer(0.5).map { 'foo' },
-    RX::Observable.timer(0.2).map { 'bar' }
+source = RxRuby::Observable.amb(
+    RxRuby::Observable.timer(0.5).map { 'foo' },
+    RxRuby::Observable.timer(0.2).map { 'bar' }
 )
 
 subscription = source.subscribe(

diff --git a/examples/ambproto.rb b/examples/ambproto.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
-first = RX::Observable.timer(0.3).map { 'first' }
-second = RX::Observable.timer(0.5).map { 'second' }
+first = RxRuby::Observable.timer(0.3).map { 'first' }
+second = RxRuby::Observable.timer(0.5).map { 'second' }
 
 source = first.amb(second)
 

diff --git a/examples/and.rb b/examples/and.rb
@@ -1,9 +1,9 @@
-require 'rx'
+require 'rx_ruby'
 
 # Choice of either plan, the first set of timers or second set
-source = RX::Observable.when(
-    RX::Observable.timer(0.2).and(RX::Observable.timer(0.3)).then_do(lambda {|x, y| return 'first' }),
-    RX::Observable.timer(0.4).and(RX::Observable.timer(0.5)).then_do(lambda {|x, y| return 'second' }),
+source = RxRuby::Observable.when(
+    RxRuby::Observable.timer(0.2).and(RxRuby::Observable.timer(0.3)).then_do(lambda {|x, y| return 'first' }),
+    RxRuby::Observable.timer(0.4).and(RxRuby::Observable.timer(0.5)).then_do(lambda {|x, y| return 'second' }),
 )
 
 subscription = source.subscribe(

diff --git a/examples/as_observable.rb b/examples/as_observable.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
 # Create subject
-subject = RX::AsyncSubject.new
+subject = RxRuby::AsyncSubject.new
 
 # Send a value
 subject.on_next(42)

diff --git a/examples/average.rb b/examples/average.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
 # Without a selector
-source = RX::Observable.range(0, 9).average
+source = RxRuby::Observable.range(0, 9).average
 
 subscription = source.subscribe(
     lambda {|x|
@@ -24,7 +24,7 @@
     { value: 3 }
 ]
 
-source = RX::Observable.from_array(arr).average {|x|
+source = RxRuby::Observable.from_array(arr).average {|x|
     x[:value]
 }
 

diff --git a/examples/buffer_with_count.rb b/examples/buffer_with_count.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
 #  Without a skip
-source = RX::Observable.range(1, 6)
+source = RxRuby::Observable.range(1, 6)
     .buffer_with_count(2)
 
 subscription = source.subscribe(
@@ -21,7 +21,7 @@
 # => Completed
 
 #  Using a skip
-source = RX::Observable.range(1, 6)
+source = RxRuby::Observable.range(1, 6)
     .buffer_with_count(2, 1)
 
 subscription = source.subscribe(

diff --git a/examples/buffer_with_time.rb b/examples/buffer_with_time.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
 #  Without a skip
-source = RX::Observable.interval(0.1)
+source = RxRuby::Observable.interval(0.1)
     .buffer_with_time(0.5)
     .take(3)
 
@@ -26,7 +26,7 @@
 end
 
 #  Using a skip
-source = RX::Observable.interval(0.1)
+source = RxRuby::Observable.interval(0.1)
     .buffer_with_time(0.5, 0.1)
     .take(3)
 

diff --git a/examples/case.rb b/examples/case.rb
@@ -1,13 +1,13 @@
-require 'rx'
+require 'rx_ruby'
 
 sources = {
-    'foo' => RX::Observable.return(42),
-    'bar' => RX::Observable.return(56)
+    'foo' => RxRuby::Observable.return(42),
+    'bar' => RxRuby::Observable.return(56)
 }
 
-defaultSource = RX::Observable.empty()
+defaultSource = RxRuby::Observable.empty()
 
-source = RX::Observable.case(
+source = RxRuby::Observable.case(
     lambda {
         'foo'
     },

diff --git a/examples/catch.rb b/examples/catch.rb
@@ -1,9 +1,9 @@
-require 'rx'
+require 'rx_ruby'
 
-obs1 = RX::Observable.raise_error(Exception.new('error'))
-obs2 = RX::Observable.return(42)
+obs1 = RxRuby::Observable.raise_error(Exception.new('error'))
+obs2 = RxRuby::Observable.return(42)
 
-source = RX::Observable.rescue_error(obs1, obs2)
+source = RxRuby::Observable.rescue_error(obs1, obs2)
 
 subscription = source.subscribe(
     lambda {|x|

diff --git a/examples/catchproto.rb b/examples/catchproto.rb
@@ -1,8 +1,8 @@
-require 'rx'
+require 'rx_ruby'
 
 #  Using a second observable
-source = RX::Observable.raise_error(Exception.new)
-    .rescue_error(RX::Observable.return(42))
+source = RxRuby::Observable.raise_error(Exception.new)
+    .rescue_error(RxRuby::Observable.return(42))
 
 subscription = source.subscribe(
     lambda {|x|
@@ -19,9 +19,9 @@
 # => Completed
 
 #  Using a handler function
-source = RX::Observable.raise_error(Exception.new)
+source = RxRuby::Observable.raise_error(Exception.new)
     .rescue_error {|e|
-        RX::Observable.return(e.is_a? Exception)
+        RxRuby::Observable.return(e.is_a? Exception)
     }
 
 subscription = source.subscribe(

diff --git a/examples/combine_latest.rb b/examples/combine_latest.rb
@@ -1,14 +1,14 @@
-require 'rx'
+require 'rx_ruby'
 
 # Have staggering intervals
-source1 = RX::Observable.interval(0.1)
+source1 = RxRuby::Observable.interval(0.1)
     .map {|i| 'First: ' + i.to_s }
 
-source2 = RX::Observable.interval(0.15)
+source2 = RxRuby::Observable.interval(0.15)
     .map {|i| 'Second: ' + i.to_s }
 
 # Combine latest of source1 and source2 whenever either gives a value
-source = RX::Observable.combine_latest(
+source = RxRuby::Observable.combine_latest(
         source1,
         source2) {|s1, s2| s1.to_s + ', ' + s2.to_s }
     .take(4)

diff --git a/examples/combine_latestproto.rb b/examples/combine_latestproto.rb
@@ -1,10 +1,10 @@
-require 'rx'
+require 'rx_ruby'
 
 #  Have staggering intervals
-source1 = RX::Observable.interval(0.1)
+source1 = RxRuby::Observable.interval(0.1)
     .map {|i| 'First: ' + i.to_s }
 
-source2 = RX::Observable.interval(0.15)
+source2 = RxRuby::Observable.interval(0.15)
     .map {|i| 'Second: ' + i.to_s }
 
 # Combine latest of source1 and source2 whenever either gives a value

diff --git a/examples/concat.rb b/examples/concat.rb
@@ -1,10 +1,10 @@
-require 'rx'
+require 'rx_ruby'
 
 #  Using Observable sequences
-source1 = RX::Observable.return(42)
-source2 = RX::Observable.return(56)
+source1 = RxRuby::Observable.return(42)
+source2 = RxRuby::Observable.return(56)
 
-source = RX::Observable.concat(source1, source2)
+source = RxRuby::Observable.concat(source1, source2)
 
 subscription = source.subscribe(
     lambda {|x|

diff --git a/examples/concat_all.rb b/examples/concat_all.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
-source = RX::Observable.range(0, 3)
-  .map {|x| RX::Observable.range(x, 3) }
+source = RxRuby::Observable.range(0, 3)
+  .map {|x| RxRuby::Observable.range(x, 3) }
   .concat_all
 
 subscription = source.subscribe(

diff --git a/examples/concat_map.rb b/examples/concat_map.rb
@@ -1,8 +1,8 @@
-require 'rx'
+require 'rx_ruby'
 
-source = RX::Observable.range(0, 5)
+source = RxRuby::Observable.range(0, 5)
     .concat_map(lambda {|x, i|
-        return RX::Observable
+        return RxRuby::Observable
             .interval(0.1)
             .take(x).map { i }
     })
@@ -35,7 +35,7 @@
 end
 
 #  Using an array
-source = RX::Observable.of(1,2,3)
+source = RxRuby::Observable.of(1,2,3)
   .concat_map(
     lambda {|x, i| return [x,i] },
     lambda {|x, y, ix, iy| return x + y + ix + iy }

diff --git a/examples/concat_map_observer.rb b/examples/concat_map_observer.rb
@@ -1,15 +1,15 @@
-require 'rx'
+require 'rx_ruby'
 
-source = RX::Observable.range(1, 3)
+source = RxRuby::Observable.range(1, 3)
     .concat_map_observer(
         lambda {|x, i|
-            return RX::Observable.repeat(x, i)
+            return RxRuby::Observable.repeat(x, i)
         },
         lambda {|err|
-            return RX::Observable.return(42)
+            return RxRuby::Observable.return(42)
         },
         lambda {
-            return RX::Observable.empty
+            return RxRuby::Observable.empty
         })
 
 subscription = source.subscribe(

diff --git a/examples/concatproto.rb b/examples/concatproto.rb
@@ -1,8 +1,8 @@
-require 'rx'
+require 'rx_ruby'
 
-source = RX::Observable
+source = RxRuby::Observable
     .return(42)
-    .concat(RX::Observable.return(56), RX::Observable.return(72))
+    .concat(RxRuby::Observable.return(56), RxRuby::Observable.return(72))
 
 subscription = source.subscribe(
     lambda {|x|

diff --git a/examples/connect.rb b/examples/connect.rb
@@ -1,13 +1,13 @@
-require 'rx'
+require 'rx_ruby'
 
-interval = RX::Observable.interval(1)
+interval = RxRuby::Observable.interval(1)
 
 source = interval
     .take(2)
     .do {|x| puts 'Side effect' }
 
 def create_observer(tag)
-    return RX::Observer.create(
+    return RxRuby::Observer.create(
         lambda {|x|
             puts 'Next: ' + tag + x.to_s
         },

diff --git a/examples/contains.rb b/examples/contains.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
 #  Without an index
-source = RX::Observable.of(42)
+source = RxRuby::Observable.of(42)
   .contains(42)
 
 subscription = source.subscribe(
@@ -19,7 +19,7 @@
 # => Completed
 
 #  With an index
-source = RX::Observable.of(1,2,3)
+source = RxRuby::Observable.of(1,2,3)
   .contains(2, 1)
 
 subscription = source.subscribe(

diff --git a/examples/count.rb b/examples/count.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
 #  Without a predicate
-source = RX::Observable.range(0, 10).count
+source = RxRuby::Observable.range(0, 10).count
 
 subscription = source.subscribe(
     lambda {|x|
@@ -18,7 +18,7 @@
 # => Completed
 
 #  With a predicate
-source = RX::Observable.range(0, 10)
+source = RxRuby::Observable.range(0, 10)
     .count {|x| x % 2 === 0 }
 
 subscription = source.subscribe(

diff --git a/examples/create.rb b/examples/create.rb
@@ -1,7 +1,7 @@
-require 'rx'
+require 'rx_ruby'
 
 #  Using a function
-source = RX::Observable.create {|observer|
+source = RxRuby::Observable.create {|observer|
     observer.on_next(42)
     observer.on_completed
 
@@ -30,12 +30,12 @@
 # => disposed
 
 #  Using a disposable
-source = RX::Observable.create {|observer|
+source = RxRuby::Observable.create {|observer|
     observer.on_next(42)
     observer.on_completed
 
     # Note that this is optional, you do not have to return this if you require no cleanup
-    RX::Disposable.create {
+    RxRuby::Disposable.create {
         puts 'disposed'
     }
 }

diff --git a/examples/debounce.rb b/examples/debounce.rb
@@ -1,4 +1,4 @@
-require 'rx'
+require 'rx_ruby'
 
 times = [
     { value: 0, time: 0.1 },
@@ -9,9 +9,9 @@
 ]
 
 # Delay each item by time and project value
-source = RX::Observable.from(times)
+source = RxRuby::Observable.from(times)
   .flat_map {|item|
-    RX::Observable.of(item[:value])
+    RxRuby::Observable.of(item[:value])
       .delay(item[:time])
   }
   .debounce 0.5 # ms