Skip to content

1.x: increase coverage of internal utils, remove unused/unnecessary items #4119

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Jun 25, 2016
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/main/java/rx/Observable.java
Original file line number Diff line number Diff line change
Expand Up @@ -9158,7 +9158,7 @@ static <T> Subscription subscribe(Subscriber<? super T> subscriber, Observable<T
Exceptions.throwIfFatal(e);
// in case the subscriber can't listen to exceptions anymore
if (subscriber.isUnsubscribed()) {
RxJavaPluginUtils.handleException(RxJavaHooks.onObservableError(e));
RxJavaHooks.onError(RxJavaHooks.onObservableError(e));
} else {
// if an unhandled error occurs executing the onSubscribe we will propagate it
try {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,14 +15,12 @@
*/
package rx.internal.operators;

import java.util.Iterator;
import java.util.NoSuchElementException;
import java.util.*;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.AtomicReference;

import rx.Notification;
import rx.*;
import rx.Observable;
import rx.Subscriber;
import rx.exceptions.Exceptions;

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,7 @@
*/
package rx.internal.operators;

import java.util.Iterator;
import java.util.NoSuchElementException;
import java.util.*;

import rx.Observable;
import rx.Subscriber;
Expand Down
9 changes: 3 additions & 6 deletions src/main/java/rx/internal/operators/BlockingOperatorNext.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,15 +15,12 @@
*/
package rx.internal.operators;

import java.util.Iterator;
import java.util.NoSuchElementException;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;

import rx.Notification;
import rx.*;
import rx.Observable;
import rx.Subscriber;
import rx.exceptions.Exceptions;

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,17 +15,10 @@
*/
package rx.internal.operators;

import java.util.concurrent.CancellationException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicReference;

import rx.Observable;
import rx.Subscriber;
import rx.Subscription;
import rx.*;

/**
* Returns a Future representing the single value emitted by an Observable.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,14 +15,11 @@
*/
package rx.internal.operators;

import java.util.Iterator;
import java.util.NoSuchElementException;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.*;
import java.util.concurrent.*;

import rx.Notification;
import rx.*;
import rx.Observable;
import rx.Subscriber;
import rx.exceptions.Exceptions;
import rx.internal.util.RxRingBuffer;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,7 @@
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicReference;

import rx.Observer;
import rx.Subscriber;
import rx.*;
import rx.functions.Action0;
import rx.subjects.Subject;
import rx.subscriptions.Subscriptions;
Expand Down
7 changes: 2 additions & 5 deletions src/main/java/rx/internal/operators/OnSubscribeAmb.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,16 +15,13 @@
*/
package rx.internal.operators;

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.*;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicReference;

import rx.*;
import rx.Observable;
import rx.Observable.OnSubscribe;
import rx.Producer;
import rx.Subscriber;
import rx.functions.Action0;
import rx.subscriptions.Subscriptions;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,8 @@

import java.util.concurrent.atomic.AtomicInteger;

import rx.*;
import rx.Observable.OnSubscribe;
import rx.Subscriber;
import rx.Subscription;
import rx.functions.Action1;
import rx.observables.ConnectableObservable;
import rx.observers.Subscribers;
Expand Down
3 changes: 1 addition & 2 deletions src/main/java/rx/internal/operators/OnSubscribeDefer.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,8 @@
*/
package rx.internal.operators;

import rx.Observable;
import rx.*;
import rx.Observable.OnSubscribe;
import rx.Subscriber;
import rx.exceptions.Exceptions;
import rx.functions.Func0;
import rx.observers.Subscribers;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import rx.*;
import rx.Observable.OnSubscribe;
import rx.observers.Subscribers;
import rx.plugins.*;
import rx.plugins.RxJavaHooks;
import rx.subscriptions.*;

/**
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/rx/internal/operators/OnSubscribeDetach.java
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

import rx.*;
import rx.Observable.OnSubscribe;
import rx.internal.util.RxJavaPluginUtils;
import rx.plugins.RxJavaHooks;

/**
* Nulls out references to upstream data structures when the source terminates or
Expand Down Expand Up @@ -80,7 +80,7 @@ public void onError(Throwable e) {
if (a != null) {
a.onError(e);
} else {
RxJavaPluginUtils.handleException(e);
RxJavaHooks.onError(e);
}
}

Expand Down
4 changes: 2 additions & 2 deletions src/main/java/rx/internal/operators/OnSubscribeFilter.java
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import rx.Observable.OnSubscribe;
import rx.exceptions.*;
import rx.functions.Func1;
import rx.internal.util.RxJavaPluginUtils;
import rx.plugins.RxJavaHooks;

/**
* Filters an Observable by discarding any items it emits that do not meet some test.
Expand Down Expand Up @@ -82,7 +82,7 @@ public void onNext(T t) {
@Override
public void onError(Throwable e) {
if (done) {
RxJavaPluginUtils.handleException(e);
RxJavaHooks.onError(e);
return;
}
done = true;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@
import rx.internal.util.*;
import rx.internal.util.atomic.*;
import rx.internal.util.unsafe.*;
import rx.plugins.RxJavaHooks;

/**
* Flattens a sequence if Iterable sources, generated via a function, into a single sequence.
Expand Down Expand Up @@ -136,7 +137,7 @@ public void onError(Throwable e) {
done = true;
drain();
} else {
RxJavaPluginUtils.handleException(e);
RxJavaHooks.onError(e);
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,12 @@

package rx.internal.operators;

import rx.Observable;
import rx.Subscriber;
import java.util.concurrent.Callable;

import rx.*;
import rx.exceptions.Exceptions;
import rx.internal.producers.SingleDelayedProducer;

import java.util.concurrent.Callable;

/**
* Do not invoke the function until an Observer subscribes; Invokes function on each
* subscription.
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/rx/internal/operators/OnSubscribeLift.java
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import rx.Observable.*;
import rx.Subscriber;
import rx.exceptions.Exceptions;
import rx.plugins.*;
import rx.plugins.RxJavaHooks;

/**
* Transforms the downstream Subscriber into a Subscriber via an operator
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/rx/internal/operators/OnSubscribeMap.java
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import rx.Observable.OnSubscribe;
import rx.exceptions.*;
import rx.functions.Func1;
import rx.internal.util.RxJavaPluginUtils;
import rx.plugins.RxJavaHooks;

/**
* Applies a function of your choosing to every item emitted by an {@code Observable}, and emits the results of
Expand Down Expand Up @@ -80,7 +80,7 @@ public void onNext(T t) {
@Override
public void onError(Throwable e) {
if (done) {
RxJavaPluginUtils.handleException(e);
RxJavaHooks.onError(e);
return;
}
done = true;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,8 @@
*/
package rx.internal.operators;

import rx.*;
import rx.Observable.OnSubscribe;
import rx.Subscriber;
import rx.exceptions.AssemblyStackTraceException;

/**
Expand Down
18 changes: 5 additions & 13 deletions src/main/java/rx/internal/operators/OnSubscribeRedo.java
Original file line number Diff line number Diff line change
Expand Up @@ -33,19 +33,11 @@

import static rx.Observable.create;

import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;

import rx.Notification;
import rx.Observable;
import rx.Observable.OnSubscribe;
import rx.Observable.Operator;
import rx.Producer;
import rx.Scheduler;
import rx.Subscriber;
import rx.functions.Action0;
import rx.functions.Func1;
import rx.functions.Func2;
import java.util.concurrent.atomic.*;

import rx.*;
import rx.Observable.*;
import rx.functions.*;
import rx.internal.producers.ProducerArbiter;
import rx.observers.Subscribers;
import rx.schedulers.Schedulers;
Expand Down
12 changes: 4 additions & 8 deletions src/main/java/rx/internal/operators/OnSubscribeRefCount.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,18 +15,14 @@
*/
package rx.internal.operators;

import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.*;
import java.util.concurrent.locks.ReentrantLock;

import rx.*;
import rx.Observable.OnSubscribe;
import rx.Subscriber;
import rx.Subscription;
import rx.functions.Action0;
import rx.functions.Action1;
import rx.functions.*;
import rx.observables.ConnectableObservable;
import rx.subscriptions.CompositeSubscription;
import rx.subscriptions.Subscriptions;
import rx.subscriptions.*;

/**
* Returns an observable sequence that stays connected to the source as long as
Expand Down
7 changes: 2 additions & 5 deletions src/main/java/rx/internal/operators/OnSubscribeSingle.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,10 @@
*/
package rx.internal.operators;

import rx.Observable;
import rx.Single;
import rx.SingleSubscriber;
import rx.Subscriber;

import java.util.NoSuchElementException;

import rx.*;

/**
* Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
* Also forwards errors as appropriate.
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/rx/internal/operators/OnSubscribeTimerOnce.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,11 @@
package rx.internal.operators;

import java.util.concurrent.TimeUnit;

import rx.*;
import rx.Observable.OnSubscribe;
import rx.Scheduler;
import rx.Scheduler.Worker;
import rx.exceptions.Exceptions;
import rx.Subscriber;
import rx.functions.Action0;

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,11 @@
package rx.internal.operators;

import java.util.concurrent.TimeUnit;

import rx.*;
import rx.Observable.OnSubscribe;
import rx.Scheduler;
import rx.Scheduler.Worker;
import rx.exceptions.Exceptions;
import rx.Subscriber;
import rx.functions.Action0;

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,11 @@
*/
package rx.internal.operators;

import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.*;

import rx.Observable.OnSubscribe;
import rx.exceptions.Exceptions;
import rx.Subscriber;
import rx.exceptions.Exceptions;
import rx.functions.Action0;
import rx.internal.producers.SingleProducer;
import rx.subscriptions.Subscriptions;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,17 +15,15 @@
*/
package rx.internal.operators;

import java.util.ArrayList;
import java.util.List;
import java.util.*;

import rx.Observable;
import rx.Observable.Operator;
import rx.exceptions.Exceptions;
import rx.Observer;
import rx.Subscriber;
import rx.exceptions.Exceptions;
import rx.functions.Func0;
import rx.observers.SerializedSubscriber;
import rx.observers.Subscribers;
import rx.observers.*;

/**
* This operation takes
Expand Down
Loading