Skip to content

Commit a17a44d

Browse files
committed
Upgrade to RxJava 2.1.14, Deprecate MulticastProcessor.
1 parent 3a21b92 commit a17a44d

File tree

5 files changed

+10
-4
lines changed

5 files changed

+10
-4
lines changed

README.md

+5-2
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ RxJava 2.x implementation of extra sources, operators and components and ports o
1313

1414
```
1515
dependencies {
16-
   compile "com.github.akarnokd:rxjava2-extensions:0.19.1"
16+
   compile "com.github.akarnokd:rxjava2-extensions:0.19.2"
1717
}
1818
```
1919

@@ -36,7 +36,7 @@ Maven search:
3636
- [Multi-hook handlers](#multi-hook-handlers)
3737
- Custom Processors and Subjects
3838
- [SoloProcessor, PerhapsProcessor and NonoProcessor](#soloprocessor-perhapsprocessor-and-nonoprocessor)
39-
- [MulticastProcessor](#multicastprocessor),
39+
- [MulticastProcessor](#multicastprocessor) *(Deprecated in 0.19.2!)*,
4040
- [UnicastWorkSubject](#unicastworksubject),
4141
- [DispatchWorkSubject](#dispatchworksubject),
4242
- [DispatchWorkProcessor](#dispatchworkprocessor)
@@ -564,6 +564,9 @@ Note that calling `onComplete` after `onNext` is optional with `SoloProcessor` b
564564
565565
### MulticastProcessor
566566
567+
*Deprecated in 0.19.2; will be removed in 0.20.0. Use the standard
568+
[`io.reactivex.processors.MulticastProcessor`](http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/processors/MulticastProcessor.html) instead*.
569+
567570
Works similarly to `publish(Function)` and multicasts items to subscribers if all of them are ready to receive the items.
568571
In addition, it supports a mode where the last subscriber cancelling will trigger a cancellation to the upstream.
569572
If you need it to run without subscribing the `MulticastProcessor` to another `Publisher` use `start()` or `startUnbounded()`.

build.gradle

+1-1
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ dependencies {
4949
signature 'org.codehaus.mojo.signature:java16:1.1@signature'
5050

5151
compile "org.reactivestreams:reactive-streams:1.0.2"
52-
compile "io.reactivex.rxjava2:rxjava:2.1.13"
52+
compile "io.reactivex.rxjava2:rxjava:2.1.14"
5353

5454
testCompile group: 'junit', name: 'junit', version: '4.12'
5555

gradle.properties

+1-1
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
version=0.19.1
1+
version=0.19.2

src/main/java/hu/akarnokd/rxjava2/processors/MulticastProcessor.java

+2
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,9 @@
3333
* subscribers have cancelled.
3434
* @param <T> the input and output value type
3535
* @since 0.16.4
36+
* @deprecated in 0.19.2 - will be removed in 0.20. Use the standard {@link io.reactivex.processors.MulticastProcessor} from now on.
3637
*/
38+
@Deprecated
3739
public final class MulticastProcessor<T> extends FlowableProcessor<T> {
3840

3941
final AtomicInteger wip;

src/test/java/hu/akarnokd/rxjava2/processors/MulticastProcessorTest.java

+1
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
import io.reactivex.processors.UnicastProcessor;
3434
import io.reactivex.subscribers.TestSubscriber;
3535

36+
@SuppressWarnings("deprecation")
3637
public class MulticastProcessorTest {
3738

3839
@Test

0 commit comments

Comments
 (0)