rx.operators -> rx.internal.operators

Author: benjchristensen

rxjava-core/src/main/java/rx/Observable.java

@@ -19,9 +19,9 @@
 
 import rx.exceptions.*;
 import rx.functions.*;
+import rx.internal.operators.*;
 import rx.observables.*;
 import rx.observers.SafeSubscriber;
-import rx.operators.*;
 import rx.plugins.*;
 import rx.schedulers.*;
 import rx.subjects.*;

rxjava-core/src/main/java/rx/operators/BlockingOperatorLatest.java renamed to rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorLatest.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.Iterator;
 import java.util.NoSuchElementException;

rxjava-core/src/main/java/rx/operators/BlockingOperatorMostRecent.java renamed to rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorMostRecent.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.Iterator;
 

rxjava-core/src/main/java/rx/operators/BlockingOperatorNext.java renamed to rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorNext.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.Iterator;
 import java.util.NoSuchElementException;

rxjava-core/src/main/java/rx/operators/BlockingOperatorToFuture.java renamed to rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorToFuture.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.CancellationException;
 import java.util.concurrent.CountDownLatch;

rxjava-core/src/main/java/rx/operators/BlockingOperatorToIterator.java renamed to rxjava-core/src/main/java/rx/internal/operators/BlockingOperatorToIterator.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.Iterator;
 import java.util.NoSuchElementException;

rxjava-core/src/main/java/rx/operators/BufferUntilSubscriber.java renamed to rxjava-core/src/main/java/rx/internal/operators/BufferUntilSubscriber.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

rxjava-core/src/main/java/rx/operators/NotificationLite.java renamed to rxjava-core/src/main/java/rx/internal/operators/NotificationLite.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.io.Serializable;
 

rxjava-core/src/main/java/rx/operators/OnSubscribeAmb.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeAmb.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.List;

rxjava-core/src/main/java/rx/operators/OnSubscribeCache.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeCache.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 

rxjava-core/src/main/java/rx/operators/OnSubscribeCombineLatest.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeCombineLatest.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.BitSet;

rxjava-core/src/main/java/rx/operators/OnSubscribeDefer.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeDefer.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable;
 import rx.Observable.OnSubscribe;

rxjava-core/src/main/java/rx/operators/OnSubscribeDelay.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeDelay.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.TimeUnit;
 

rxjava-core/src/main/java/rx/operators/OnSubscribeDelaySubscription.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeDelaySubscription.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.TimeUnit;
 import rx.Observable;

rxjava-core/src/main/java/rx/operators/OnSubscribeDelayWithSelector.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeDelayWithSelector.java

@@ -13,15 +13,15 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable;
 import rx.Observable.OnSubscribe;
 import rx.Subscriber;
 import rx.functions.Func0;
 import rx.functions.Func1;
+import rx.internal.operators.OnSubscribeDelay.Emitter;
 import rx.observers.SerializedSubscriber;
-import rx.operators.OnSubscribeDelay.Emitter;
 import rx.subscriptions.CompositeSubscription;
 
 /**

rxjava-core/src/main/java/rx/operators/OnSubscribeFromIterable.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeFromIterable.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.OnSubscribe;
 import rx.Subscriber;

rxjava-core/src/main/java/rx/operators/OnSubscribeGroupJoin.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeGroupJoin.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.HashMap;

rxjava-core/src/main/java/rx/operators/OnSubscribeJoin.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeJoin.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.HashMap;

rxjava-core/src/main/java/rx/operators/OnSubscribeMulticastSelector.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeMulticastSelector.java

@@ -13,7 +13,7 @@
   * License for the specific language governing permissions and limitations under
   * the License.
   */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable;
 import rx.Observable.OnSubscribe;

rxjava-core/src/main/java/rx/operators/OnSubscribeRange.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeRange.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.OnSubscribe;
 import rx.Subscriber;

rxjava-core/src/main/java/rx/operators/OnSubscribeRefCount.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeRefCount.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.List;

rxjava-core/src/main/java/rx/operators/OnSubscribeTimerOnce.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeTimerOnce.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.TimeUnit;
 import rx.Observable.OnSubscribe;

rxjava-core/src/main/java/rx/operators/OnSubscribeTimerPeriodically.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeTimerPeriodically.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.TimeUnit;
 import rx.Observable.OnSubscribe;

rxjava-core/src/main/java/rx/operators/OnSubscribeToObservableFuture.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeToObservableFuture.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;

rxjava-core/src/main/java/rx/operators/OnSubscribeUsing.java renamed to rxjava-core/src/main/java/rx/internal/operators/OnSubscribeUsing.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable;
 import rx.Observable.OnSubscribe;

rxjava-core/src/main/java/rx/operators/OperatorAll.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorAll.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.Operator;
 import rx.Subscriber;

rxjava-core/src/main/java/rx/operators/OperatorAny.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorAny.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 
 import rx.Observable;

rxjava-core/src/main/java/rx/operators/OperatorAsObservable.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorAsObservable.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.Operator;
 import rx.Subscriber;

rxjava-core/src/main/java/rx/operators/OperatorBufferWithSingleObservable.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorBufferWithSingleObservable.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.List;

rxjava-core/src/main/java/rx/operators/OperatorBufferWithSize.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorBufferWithSize.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.Iterator;

rxjava-core/src/main/java/rx/operators/OperatorBufferWithStartEndObservable.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorBufferWithStartEndObservable.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.Iterator;

rxjava-core/src/main/java/rx/operators/OperatorBufferWithTime.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorBufferWithTime.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.ArrayList;
 import java.util.Iterator;

rxjava-core/src/main/java/rx/operators/OperatorCast.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorCast.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.Operator;
 import rx.Subscriber;

rxjava-core/src/main/java/rx/operators/OperatorConcat.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorConcat.java

@@ -13,7 +13,7 @@
   * License for the specific language governing permissions and limitations under
   * the License.
   */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

rxjava-core/src/main/java/rx/operators/OperatorDebounceWithSelector.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorDebounceWithSelector.java

@@ -13,14 +13,14 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable;
 import rx.Observable.Operator;
 import rx.Subscriber;
 import rx.functions.Func1;
+import rx.internal.operators.OperatorDebounceWithTime.DebounceState;
 import rx.observers.SerializedSubscriber;
-import rx.operators.OperatorDebounceWithTime.DebounceState;
 import rx.subscriptions.SerialSubscription;
 
 /**

rxjava-core/src/main/java/rx/operators/OperatorDebounceWithTime.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorDebounceWithTime.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.concurrent.TimeUnit;
 import rx.Observable.Operator;

rxjava-core/src/main/java/rx/operators/OperatorDefaultIfEmpty.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorDefaultIfEmpty.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.Operator;
 import rx.Subscriber;

rxjava-core/src/main/java/rx/operators/OperatorDematerialize.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorDematerialize.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Notification;
 import rx.Observable.Operator;

rxjava-core/src/main/java/rx/operators/OperatorDistinct.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorDistinct.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import java.util.HashSet;
 import java.util.Set;

rxjava-core/src/main/java/rx/operators/OperatorDistinctUntilChanged.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorDistinctUntilChanged.java

@@ -13,7 +13,7 @@
  * License for the specific language governing permissions and limitations under
  * the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.Operator;
 import rx.Subscriber;

rxjava-core/src/main/java/rx/operators/OperatorDoOnEach.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorDoOnEach.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.Operator;
 import rx.Observer;

rxjava-core/src/main/java/rx/operators/OperatorElementAt.java renamed to rxjava-core/src/main/java/rx/internal/operators/OperatorElementAt.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.operators;
+package rx.internal.operators;
 
 import rx.Observable.Operator;
 import rx.Subscriber;