rx.Observer



API Populatity

9 Client projects

Project: rx

API Migration
408 ➜ rx.Subscriber (snippets)
Project Netflix/RxJava in file ...st.java.rx.operators.OperationMaterializeTest.java (2014-01-30)
@@ -26,6 +26,7 @@ import org.junit.Test;
 
 import rx.Notification;
 import rx.Observable;
+import rx.Observer;
 import rx.Subscriber;
 import rx.Subscription;
 
@@ -127,7 +128,7 @@ public class OperationMaterializeTest {
         volatile Thread t;
 
         @Override
-        public Subscription onSubscribe(final Subscriber<? super String> observer) {
+        public Subscription onSubscribe(final Observer<? super String> observer) {
             t = new Thread(new Runnable() {
 
                 @Override
Project Netflix/RxJava in file ...rc.test.java.rx.operators.OperatorGroupByTest.java (2014-01-30)
@@ -31,6 +31,7 @@ import org.junit.Test;
 
 import rx.Observable;
 import rx.Observable.OnSubscribe;
+import rx.Observer;
 import rx.Subscriber;
 import rx.Subscription;
 import rx.observables.GroupedObservable;
@@ -163,7 +164,7 @@ public class OperatorGroupByTest {
         Observable<Event> es = Observable.create(new Observable.OnSubscribeFunc<Event>() {
 
             @Override
-            public Subscription onSubscribe(final Subscriber<? super Event> observer) {
+            public Subscription onSubscribe(final Observer<? super Event> observer) {
                 System.out.println("*** Subscribing to EventStream ***");
                 subscribeCounter.incrementAndGet();
                 new Thread(new Runnable() {
Project Netflix/RxJava in file ....schedulers.AbstractSchedulerConcurrencyTests.java (2014-01-30)
@@ -26,6 +26,7 @@ import org.junit.Test;
 
 import rx.Observable;
 import rx.Observable.OnSubscribeFunc;
+import rx.Observer;
 import rx.Scheduler;
 import rx.Subscriber;
 import rx.Subscription;
@@ -217,7 +218,7 @@ public abstract class AbstractSchedulerConcurrencyTests extends AbstractSchedule
 
         Observable<Integer> obs = Observable.create(new OnSubscribeFunc<Integer>() {
             @Override
-            public Subscription onSubscribe(final Subscriber<? super Integer> observer) {
+            public Subscription onSubscribe(final Observer<? super Integer> observer) {
 
                 return getScheduler().schedule(null, new Func2<Scheduler, Void, Subscription>() {
                     @Override