Upgrade to RxJava 2.1.14, Deprecate MulticastProcessor.

akarnokd · May 23, 2018 · a17a44d · a17a44d
1 parent 3a21b92
commit a17a44d
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -13,7 +13,7 @@ RxJava 2.x implementation of extra sources, operators and components and ports o
 
 ```
 dependencies {
-    compile "com.github.akarnokd:rxjava2-extensions:0.19.1"
+    compile "com.github.akarnokd:rxjava2-extensions:0.19.2"
 }
 ```
 
@@ -36,7 +36,7 @@ Maven search:
     - [Multi-hook handlers](#multi-hook-handlers)
   - Custom Processors and Subjects
     - [SoloProcessor, PerhapsProcessor and NonoProcessor](#soloprocessor-perhapsprocessor-and-nonoprocessor)
-    - [MulticastProcessor](#multicastprocessor),
+    - [MulticastProcessor](#multicastprocessor) *(Deprecated in 0.19.2!)*,
     - [UnicastWorkSubject](#unicastworksubject),
     - [DispatchWorkSubject](#dispatchworksubject),
     - [DispatchWorkProcessor](#dispatchworkprocessor)
@@ -564,6 +564,9 @@ Note that calling `onComplete` after `onNext` is optional with `SoloProcessor` b
 
 ### MulticastProcessor
 
+*Deprecated in 0.19.2; will be removed in 0.20.0. Use the standard 
+[`io.reactivex.processors.MulticastProcessor`](http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/processors/MulticastProcessor.html) instead*.
+
 Works similarly to `publish(Function)` and multicasts items to subscribers if all of them are ready to receive the items.
 In addition, it supports a mode where the last subscriber cancelling will trigger a cancellation to the upstream.
 If you need it to run without subscribing the `MulticastProcessor` to another `Publisher` use `start()` or `startUnbounded()`.

diff --git a/build.gradle b/build.gradle
@@ -49,7 +49,7 @@ dependencies {
     signature 'org.codehaus.mojo.signature:java16:1.1@signature'
 
     compile "org.reactivestreams:reactive-streams:1.0.2"
-    compile "io.reactivex.rxjava2:rxjava:2.1.13"
+    compile "io.reactivex.rxjava2:rxjava:2.1.14"
 
     testCompile group: 'junit', name: 'junit', version: '4.12'
 

diff --git a/gradle.properties b/gradle.properties
@@ -1 +1 @@
-version=0.19.1
+version=0.19.2
diff --git a/src/main/java/hu/akarnokd/rxjava2/processors/MulticastProcessor.java b/src/main/java/hu/akarnokd/rxjava2/processors/MulticastProcessor.java
@@ -33,7 +33,9 @@
  * subscribers have cancelled.
  * @param <T> the input and output value type
  * @since 0.16.4
+ * @deprecated in 0.19.2 - will be removed in 0.20. Use the standard {@link io.reactivex.processors.MulticastProcessor} from now on.
  */
+@Deprecated
 public final class MulticastProcessor<T> extends FlowableProcessor<T> {
 
     final AtomicInteger wip;

diff --git a/src/test/java/hu/akarnokd/rxjava2/processors/MulticastProcessorTest.java b/src/test/java/hu/akarnokd/rxjava2/processors/MulticastProcessorTest.java
@@ -33,6 +33,7 @@
 import io.reactivex.processors.UnicastProcessor;
 import io.reactivex.subscribers.TestSubscriber;
 
+@SuppressWarnings("deprecation")
 public class MulticastProcessorTest {
 
     @Test