ReactiveX · benjchristensen · May 30, 2014 · May 30, 2014
diff --git a/rxjava-core/src/main/java/rx/Observable.java b/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.*;

diff --git a/.../rx/operators/BlockingOperatorLatest.java → ...nal/operators/BlockingOperatorLatest.java b/.../rx/operators/BlockingOperatorLatest.java → ...nal/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;

diff --git a/...operators/BlockingOperatorMostRecent.java → ...operators/BlockingOperatorMostRecent.java b/...operators/BlockingOperatorMostRecent.java → ...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;
 

diff --git a/...va/rx/operators/BlockingOperatorNext.java → ...ernal/operators/BlockingOperatorNext.java b/...va/rx/operators/BlockingOperatorNext.java → ...ernal/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;

diff --git a/...x/operators/BlockingOperatorToFuture.java → ...l/operators/BlockingOperatorToFuture.java b/...x/operators/BlockingOperatorToFuture.java → ...l/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;

diff --git a/...operators/BlockingOperatorToIterator.java → ...operators/BlockingOperatorToIterator.java b/...operators/BlockingOperatorToIterator.java → ...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;

diff --git a/...a/rx/operators/BufferUntilSubscriber.java → ...rnal/operators/BufferUntilSubscriber.java b/...a/rx/operators/BufferUntilSubscriber.java → ...rnal/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;

diff --git a/...n/java/rx/operators/NotificationLite.java → .../internal/operators/NotificationLite.java b/...n/java/rx/operators/NotificationLite.java → .../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;
 

diff --git a/...ain/java/rx/operators/OnSubscribeAmb.java → ...rx/internal/operators/OnSubscribeAmb.java b/...ain/java/rx/operators/OnSubscribeAmb.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;

diff --git a/...n/java/rx/operators/OnSubscribeCache.java → .../internal/operators/OnSubscribeCache.java b/...n/java/rx/operators/OnSubscribeCache.java → .../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;
 

diff --git a/...x/operators/OnSubscribeCombineLatest.java → ...l/operators/OnSubscribeCombineLatest.java b/...x/operators/OnSubscribeCombineLatest.java → ...l/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;

diff --git a/...n/java/rx/operators/OnSubscribeDefer.java → .../internal/operators/OnSubscribeDefer.java b/...n/java/rx/operators/OnSubscribeDefer.java → .../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;

diff --git a/...n/java/rx/operators/OnSubscribeDelay.java → .../internal/operators/OnSubscribeDelay.java b/...n/java/rx/operators/OnSubscribeDelay.java → .../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;
 

diff --git a/...erators/OnSubscribeDelaySubscription.java → ...erators/OnSubscribeDelaySubscription.java b/...erators/OnSubscribeDelaySubscription.java → ...erators/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;

diff --git a/...erators/OnSubscribeDelayWithSelector.java → ...erators/OnSubscribeDelayWithSelector.java b/...erators/OnSubscribeDelayWithSelector.java → ...erators/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;
 
 /**

diff --git a/...rx/operators/OnSubscribeFromIterable.java → ...al/operators/OnSubscribeFromIterable.java b/...rx/operators/OnSubscribeFromIterable.java → ...al/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;

diff --git a/...va/rx/operators/OnSubscribeGroupJoin.java → ...ernal/operators/OnSubscribeGroupJoin.java b/...va/rx/operators/OnSubscribeGroupJoin.java → ...ernal/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;

diff --git a/...in/java/rx/operators/OnSubscribeJoin.java → ...x/internal/operators/OnSubscribeJoin.java b/...in/java/rx/operators/OnSubscribeJoin.java → ...x/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;

diff --git a/...erators/OnSubscribeMulticastSelector.java → ...erators/OnSubscribeMulticastSelector.java b/...erators/OnSubscribeMulticastSelector.java → ...erators/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;

diff --git a/...n/java/rx/operators/OnSubscribeRange.java → .../internal/operators/OnSubscribeRange.java b/...n/java/rx/operators/OnSubscribeRange.java → .../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;

diff --git a/...ava/rx/operators/OnSubscribeRefCount.java → ...ternal/operators/OnSubscribeRefCount.java b/...ava/rx/operators/OnSubscribeRefCount.java → ...ternal/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;

diff --git a/...va/rx/operators/OnSubscribeTimerOnce.java → ...ernal/operators/OnSubscribeTimerOnce.java b/...va/rx/operators/OnSubscribeTimerOnce.java → ...ernal/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;

diff --git a/...erators/OnSubscribeTimerPeriodically.java → ...erators/OnSubscribeTimerPeriodically.java b/...erators/OnSubscribeTimerPeriodically.java → ...erators/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;

diff --git a/...rators/OnSubscribeToObservableFuture.java → ...rators/OnSubscribeToObservableFuture.java b/...rators/OnSubscribeToObservableFuture.java → ...rators/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;

diff --git a/...n/java/rx/operators/OnSubscribeUsing.java → .../internal/operators/OnSubscribeUsing.java b/...n/java/rx/operators/OnSubscribeUsing.java → .../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;

diff --git a/...c/main/java/rx/operators/OperatorAll.java → ...va/rx/internal/operators/OperatorAll.java b/...c/main/java/rx/operators/OperatorAll.java → ...va/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;

diff --git a/...c/main/java/rx/operators/OperatorAny.java → ...va/rx/internal/operators/OperatorAny.java b/...c/main/java/rx/operators/OperatorAny.java → ...va/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;

diff --git a/...va/rx/operators/OperatorAsObservable.java → ...ernal/operators/OperatorAsObservable.java b/...va/rx/operators/OperatorAsObservable.java → ...ernal/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;

diff --git a/...s/OperatorBufferWithSingleObservable.java → ...s/OperatorBufferWithSingleObservable.java b/...s/OperatorBufferWithSingleObservable.java → ...s/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;

diff --git a/.../rx/operators/OperatorBufferWithSize.java → ...nal/operators/OperatorBufferWithSize.java b/.../rx/operators/OperatorBufferWithSize.java → ...nal/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;

diff --git a/...OperatorBufferWithStartEndObservable.java → ...OperatorBufferWithStartEndObservable.java b/...OperatorBufferWithStartEndObservable.java → ...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;

diff --git a/.../rx/operators/OperatorBufferWithTime.java → ...nal/operators/OperatorBufferWithTime.java b/.../rx/operators/OperatorBufferWithTime.java → ...nal/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;

diff --git a/.../main/java/rx/operators/OperatorCast.java → ...a/rx/internal/operators/OperatorCast.java b/.../main/java/rx/operators/OperatorCast.java → ...a/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;

diff --git a/...ain/java/rx/operators/OperatorConcat.java → ...rx/internal/operators/OperatorConcat.java b/...ain/java/rx/operators/OperatorConcat.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;

diff --git a/...erators/OperatorDebounceWithSelector.java → ...erators/OperatorDebounceWithSelector.java b/...erators/OperatorDebounceWithSelector.java → ...erators/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;
 
 /**

diff --git a/...x/operators/OperatorDebounceWithTime.java → ...l/operators/OperatorDebounceWithTime.java b/...x/operators/OperatorDebounceWithTime.java → ...l/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;

diff --git a/.../rx/operators/OperatorDefaultIfEmpty.java → ...nal/operators/OperatorDefaultIfEmpty.java b/.../rx/operators/OperatorDefaultIfEmpty.java → ...nal/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;

diff --git a/...a/rx/operators/OperatorDematerialize.java → ...rnal/operators/OperatorDematerialize.java b/...a/rx/operators/OperatorDematerialize.java → ...rnal/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;

diff --git a/...n/java/rx/operators/OperatorDistinct.java → .../internal/operators/OperatorDistinct.java b/...n/java/rx/operators/OperatorDistinct.java → .../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;

diff --git a/...erators/OperatorDistinctUntilChanged.java → ...erators/OperatorDistinctUntilChanged.java b/...erators/OperatorDistinctUntilChanged.java → ...erators/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;

diff --git a/...n/java/rx/operators/OperatorDoOnEach.java → .../internal/operators/OperatorDoOnEach.java b/...n/java/rx/operators/OperatorDoOnEach.java → .../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;

diff --git a/.../java/rx/operators/OperatorElementAt.java → ...internal/operators/OperatorElementAt.java b/.../java/rx/operators/OperatorElementAt.java → ...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;