Deprecate parallel and extra subjects

Author: akarnokd

README.md

@@ -99,6 +99,8 @@ Flowable.just(5, 1, 3, 2, 4)
 
 ## Parallel operations
 
+**Deprecated in 0.14.4, functions moved to `io.reactivex.parallel.ParallelFlowable` in RxJava 2.0.5; this will be removed when RxJava 2.1 becomes available.**
+
 RxJava is sequential by nature and you can achieve parallelism by having parallel sequences. Forking out
 and joining a single sequence can become complicated and incurs quite an overhead. By using the `ParallelFlowable`
 API, the forking and joining of parallel computations started in and ending in a Flowable is more efficient than
@@ -425,6 +427,9 @@ if (assembled != null) {
 
 ## SingleSubject, MaybeSubject and CompletableSubject
 
+**Deprecated in 0.14.4, functions moved to `io.reactivex.subjects.*` in RxJava 2.0.5; they will be removed when RxJava 2.1 becomes available.**
+
+
 These are the hot variants of the respective base reactive types.
 
 ```java

gradle.properties

@@ -1 +1 @@
-version=0.14.3
+version=0.14.4

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelCollect.java

@@ -32,6 +32,7 @@
  * @param <T> the input value type
  * @param <C> the collection type
  */
+@SuppressWarnings("deprecation")
 final class ParallelCollect<T, C> extends ParallelFlowable<C> {
 
     final ParallelFlowable<? extends T> source;

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelConcatMap.java

@@ -29,6 +29,7 @@
  * @param <T> the input value type
  * @param <R> the output value type
  */
+@SuppressWarnings("deprecation")
 final class ParallelConcatMap<T, R> extends ParallelFlowable<R> {
 
     final ParallelFlowable<T> source;

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelFilter.java

@@ -28,6 +28,7 @@
  *
  * @param <T> the input value type
  */
+@SuppressWarnings("deprecation")
 final class ParallelFilter<T> extends ParallelFlowable<T> {
 
     final ParallelFlowable<T> source;

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelFlatMap.java

@@ -28,6 +28,7 @@
  * @param <T> the input value type
  * @param <R> the output value type
  */
+@SuppressWarnings("deprecation")
 final class ParallelFlatMap<T, R> extends ParallelFlowable<R> {
 
     final ParallelFlowable<T> source;

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelFlowable.java

@@ -37,7 +37,10 @@
  * Use {@code sequential()} to merge the sources back into a single Flowable.
  *
  * @param <T> the value type
+ * @deprecation 0.14.4: moved to io.reactivex.parallel.ParallelFlowable in RxJava 2.0.5;
+ * will be removed when RxJava 2.1 comes out
  */
+@Deprecated
 public abstract class ParallelFlowable<T> {
 
     /**

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelFromArray.java

@@ -25,6 +25,7 @@
  *
  * @param <T> the value type
  */
+@SuppressWarnings("deprecation")
 final class ParallelFromArray<T> extends ParallelFlowable<T> {
     final Publisher<T>[] sources;
 

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelFromPublisher.java

@@ -32,6 +32,7 @@
  *
  * @param <T> the value type
  */
+@SuppressWarnings("deprecation")
 final class ParallelFromPublisher<T> extends ParallelFlowable<T> {
     final Publisher<? extends T> source;
 

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelJoin.java

@@ -34,6 +34,7 @@
  *
  * @param <T> the value type
  */
+@SuppressWarnings("deprecation")
 final class ParallelJoin<T> extends Flowable<T> {
 
     final ParallelFlowable<? extends T> source;