Merge pull request #16 from abersnaze/upgrade-rxjava

fixing an error when using rxjava 1.0.12.
ReactiveX · Jun 29, 2015 · 4e1568c · 4e1568c
2 parents 0a2f070 + 4514faa
commit 4e1568c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/build.gradle b/build.gradle
@@ -7,7 +7,7 @@ apply plugin: 'rxjava-project'
 apply plugin: 'java'
 
 dependencies {
-    compile 'io.reactivex:rxjava:1.0.+'
+    compile 'io.reactivex:rxjava:1.0.12'
     compile 'com.google.guava:guava:+'
     testCompile 'junit:junit-dep:4.10'
     testCompile 'org.mockito:mockito-core:1.8.5'

diff --git a/src/main/java/rx/observable/ListenableFutureObservable.java b/src/main/java/rx/observable/ListenableFutureObservable.java
@@ -21,7 +21,7 @@
 import rx.Observable;
 import rx.Observable.OnSubscribe;
 import rx.functions.Action0;
-import rx.internal.operators.SingleDelayedProducer;
+import rx.internal.producers.SingleDelayedProducer;
 import rx.Observer;
 import rx.Scheduler;
 import rx.Scheduler.Worker;
@@ -76,7 +76,7 @@ public void call(final Subscriber<? super T> subscriber) {
                     public void run() {
                         try {
                             T t = future.get();
-                            sdp.set(t);
+                            sdp.setValue(t);
                         } catch (Exception e) {
                             subscriber.onError(e);
                         }