Move rxjava2-extensions files from original package to project-specific package

Author: akaita

rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/RxJava2Debug.java

@@ -16,13 +16,11 @@
 
 package com.akaita.java.rxjava2debug;
 
-import hu.akarnokd.rxjava2.debug.RxJavaAssemblyException;
-import hu.akarnokd.rxjava2.debug.RxJavaAssemblyTracking;
+import com.akaita.java.rxjava2debug.extensions.RxJavaAssemblyException;
+import com.akaita.java.rxjava2debug.extensions.RxJavaAssemblyTracking;
 import io.reactivex.annotations.NonNull;
 import io.reactivex.annotations.Nullable;
 
-import java.util.List;
-
 import static com.akaita.java.rxjava2debug.ExceptionUtils.setRootCause;
 import static com.akaita.java.rxjava2debug.StackTraceUtils.parseStackTrace;
 

rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/StackTraceUtils.java

@@ -16,7 +16,7 @@
 
 package com.akaita.java.rxjava2debug;
 
-import hu.akarnokd.rxjava2.debug.RxJavaAssemblyException;
+import com.akaita.java.rxjava2debug.extensions.RxJavaAssemblyException;
 import io.reactivex.annotations.NonNull;
 import io.reactivex.annotations.Nullable;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/CompletableOnAssembly.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/CompletableOnAssembly.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import io.reactivex.*;
 import io.reactivex.disposables.Disposable;

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/CompletableOnAssemblyCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/CompletableOnAssemblyCallable.java

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import java.util.concurrent.Callable;
 
-import hu.akarnokd.rxjava2.debug.CompletableOnAssembly.OnAssemblyCompletableObserver;
+import com.akaita.java.rxjava2debug.extensions.CompletableOnAssembly.OnAssemblyCompletableObserver;
 import io.reactivex.*;
 import io.reactivex.exceptions.Exceptions;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/CompletableOnAssemblyScalarCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/CompletableOnAssemblyScalarCallable.java

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
-import hu.akarnokd.rxjava2.debug.CompletableOnAssembly.OnAssemblyCompletableObserver;
+import com.akaita.java.rxjava2debug.extensions.CompletableOnAssembly.OnAssemblyCompletableObserver;
 import io.reactivex.*;
 import io.reactivex.internal.fuseable.ScalarCallable;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/FlowableOnAssembly.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/FlowableOnAssembly.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import org.reactivestreams.*;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/FlowableOnAssemblyCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/FlowableOnAssemblyCallable.java

@@ -14,13 +14,13 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import java.util.concurrent.Callable;
 
 import org.reactivestreams.*;
 
-import hu.akarnokd.rxjava2.debug.FlowableOnAssembly.*;
+import com.akaita.java.rxjava2debug.extensions.FlowableOnAssembly.*;
 import io.reactivex.Flowable;
 import io.reactivex.exceptions.Exceptions;
 import io.reactivex.internal.fuseable.ConditionalSubscriber;

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/FlowableOnAssemblyConnectable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/FlowableOnAssemblyConnectable.java

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import org.reactivestreams.Subscriber;
 
-import hu.akarnokd.rxjava2.debug.FlowableOnAssembly.*;
+import com.akaita.java.rxjava2debug.extensions.FlowableOnAssembly.*;
 import io.reactivex.disposables.Disposable;
 import io.reactivex.flowables.ConnectableFlowable;
 import io.reactivex.functions.Consumer;

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/FlowableOnAssemblyScalarCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/FlowableOnAssemblyScalarCallable.java

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import org.reactivestreams.*;
 
-import hu.akarnokd.rxjava2.debug.FlowableOnAssembly.*;
+import com.akaita.java.rxjava2debug.extensions.FlowableOnAssembly.*;
 import io.reactivex.Flowable;
 import io.reactivex.internal.fuseable.*;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/MaybeOnAssembly.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/MaybeOnAssembly.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import io.reactivex.*;
 import io.reactivex.disposables.Disposable;

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/MaybeOnAssemblyCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/MaybeOnAssemblyCallable.java

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import java.util.concurrent.Callable;
 
-import hu.akarnokd.rxjava2.debug.MaybeOnAssembly.OnAssemblyMaybeObserver;
+import com.akaita.java.rxjava2debug.extensions.MaybeOnAssembly.OnAssemblyMaybeObserver;
 import io.reactivex.*;
 import io.reactivex.exceptions.Exceptions;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/MaybeOnAssemblyScalarCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/MaybeOnAssemblyScalarCallable.java

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
-import hu.akarnokd.rxjava2.debug.MaybeOnAssembly.OnAssemblyMaybeObserver;
+import com.akaita.java.rxjava2debug.extensions.MaybeOnAssembly.OnAssemblyMaybeObserver;
 import io.reactivex.*;
 import io.reactivex.internal.fuseable.ScalarCallable;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/ObservableOnAssembly.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/ObservableOnAssembly.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import io.reactivex.*;
 import io.reactivex.internal.fuseable.QueueDisposable;

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/ObservableOnAssemblyCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/ObservableOnAssemblyCallable.java

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import java.util.concurrent.Callable;
 
-import hu.akarnokd.rxjava2.debug.ObservableOnAssembly.OnAssemblyObserver;
+import com.akaita.java.rxjava2debug.extensions.ObservableOnAssembly.OnAssemblyObserver;
 import io.reactivex.*;
 import io.reactivex.exceptions.Exceptions;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/ObservableOnAssemblyConnectable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/ObservableOnAssemblyConnectable.java

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
-import hu.akarnokd.rxjava2.debug.ObservableOnAssembly.OnAssemblyObserver;
+import com.akaita.java.rxjava2debug.extensions.ObservableOnAssembly.OnAssemblyObserver;
 import io.reactivex.Observer;
 import io.reactivex.disposables.Disposable;
 import io.reactivex.functions.Consumer;

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/ObservableOnAssemblyScalarCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/ObservableOnAssemblyScalarCallable.java

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
-import hu.akarnokd.rxjava2.debug.ObservableOnAssembly.OnAssemblyObserver;
+import com.akaita.java.rxjava2debug.extensions.ObservableOnAssembly.OnAssemblyObserver;
 import io.reactivex.*;
 import io.reactivex.internal.fuseable.ScalarCallable;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/ParallelFlowableOnAssembly.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/ParallelFlowableOnAssembly.java

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import org.reactivestreams.Subscriber;
 
-import hu.akarnokd.rxjava2.debug.FlowableOnAssembly.*;
+import com.akaita.java.rxjava2debug.extensions.FlowableOnAssembly.*;
 import io.reactivex.internal.fuseable.ConditionalSubscriber;
 import io.reactivex.parallel.ParallelFlowable;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/RxJavaAssemblyException.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/RxJavaAssemblyException.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import java.util.*;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/RxJavaAssemblyTracking.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/RxJavaAssemblyTracking.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import java.util.concurrent.Callable;
 import java.util.concurrent.atomic.AtomicBoolean;

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/SingleOnAssembly.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/SingleOnAssembly.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import io.reactivex.*;
 import io.reactivex.disposables.Disposable;

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/SingleOnAssemblyCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/SingleOnAssemblyCallable.java

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
 import java.util.concurrent.Callable;
 
-import hu.akarnokd.rxjava2.debug.SingleOnAssembly.OnAssemblySingleObserver;
+import com.akaita.java.rxjava2debug.extensions.SingleOnAssembly.OnAssemblySingleObserver;
 import io.reactivex.*;
 import io.reactivex.exceptions.Exceptions;
 

rxjava2debug/src/main/java/hu/akarnokd/rxjava2/debug/SingleOnAssemblyScalarCallable.java rxjava2debug/src/main/java/com/akaita/java/rxjava2debug/extensions/SingleOnAssemblyScalarCallable.java

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package hu.akarnokd.rxjava2.debug;
+package com.akaita.java.rxjava2debug.extensions;
 
-import hu.akarnokd.rxjava2.debug.SingleOnAssembly.OnAssemblySingleObserver;
+import com.akaita.java.rxjava2debug.extensions.SingleOnAssembly.OnAssemblySingleObserver;
 import io.reactivex.*;
 import io.reactivex.internal.fuseable.ScalarCallable;
 

rxjava2debug/src/test/java/hu/akarnokd/rxjava2/debug/RxJava2AssemblyTrackingTest.java

@@ -21,6 +21,8 @@
 import java.io.IOException;
 import java.util.concurrent.*;
 
+import com.akaita.java.rxjava2debug.extensions.RxJavaAssemblyException;
+import com.akaita.java.rxjava2debug.extensions.RxJavaAssemblyTracking;
 import org.junit.Test;
 
 import io.reactivex.*;